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