public static final class Association.QueueWrapperImpl extends java.lang.Object implements Association.QueueWrapper, scala.Product, scala.Serializable
Constructor and Description |
---|
QueueWrapperImpl(java.util.Queue<OutboundEnvelope> queue) |
Modifier and Type | Method and Description |
---|---|
boolean |
isEnabled() |
boolean |
offer(OutboundEnvelope message) |
java.util.Queue<OutboundEnvelope> |
queue() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public QueueWrapperImpl(java.util.Queue<OutboundEnvelope> queue)
public java.util.Queue<OutboundEnvelope> queue()
queue
in interface Association.QueueWrapper
public boolean offer(OutboundEnvelope message)
offer
in interface SendQueue.ProducerApi<OutboundEnvelope>
public boolean isEnabled()
isEnabled
in interface SendQueue.ProducerApi<OutboundEnvelope>