Class Channel.SendQueue

All Implemented Interfaces:
Serializable, Iterable<IBuffer>, Collection<IBuffer>, Queue<IBuffer>
Enclosing class:
Channel

protected class Channel.SendQueue extends ConcurrentLinkedQueue<IBuffer>
A queue that holds buffers that shall be sent. This implementation notifies observers of enqueued and dequeued buffers. The notification is deliberately not synchronized. It shall only be used by O&M tooling to offer (not 100% accurate) statistical insights
Since:
3.0
Author:
Eike Stepper
See Also: