com.caucho.message.common
Class AbstractMessageSender<T>
java.lang.Object
com.caucho.message.common.AbstractQueueSender<T>
com.caucho.message.common.AbstractMessageSender<T>
- All Implemented Interfaces:
- MessageSender<T>, java.lang.Iterable<T>, java.util.Collection<T>, java.util.concurrent.BlockingQueue<T>, java.util.Queue<T>
- Direct Known Subclasses:
- LocalSender, NautilusClientSender
public abstract class AbstractMessageSender<T>
- extends AbstractQueueSender<T>
- implements MessageSender<T>
local connection to the message store
Methods inherited from class com.caucho.message.common.AbstractQueueSender |
add, addAll, clear, contains, containsAll, drainTo, drainTo, element, getMessageFactory, isEmpty, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, remove, removeAll, retainAll, size, take, toArray, toArray |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface java.util.concurrent.BlockingQueue |
add, contains, drainTo, drainTo, offer, offer, poll, put, remainingCapacity, remove, take |
Methods inherited from interface java.util.Queue |
element, peek, poll, remove |
Methods inherited from interface java.util.Collection |
addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, removeAll, retainAll, size, toArray, toArray |
AbstractMessageSender
protected AbstractMessageSender(MessageSenderFactory factory)
getSettleMode
public final SettleMode getSettleMode()
- Description copied from interface:
MessageSender
- Auto-settle sends messages without waiting for confirmation
from the broker.
- Specified by:
getSettleMode
in interface MessageSender<T>
getSettleListener
public final MessageSettleListener getSettleListener()
- Specified by:
getSettleListener
in interface MessageSender<T>
createMessageFactory
public MessagePropertiesFactory<T> createMessageFactory()
- Specified by:
createMessageFactory
in interface MessageSender<T>
getUnsettledCount
public int getUnsettledCount()
- Specified by:
getUnsettledCount
in interface MessageSender<T>
offerMicros
protected abstract boolean offerMicros(MessagePropertiesFactory<T> factory,
T value,
long timeoutMicros)
- Offers a value to the queue.
- Specified by:
offerMicros
in class AbstractQueueSender<T>
toString
public java.lang.String toString()
- Overrides:
toString
in class AbstractQueueSender<T>