com.caucho.message.tourmaline
Class NautilusClientSender<T>
java.lang.Object
com.caucho.message.common.AbstractQueueSender<T>
com.caucho.message.common.AbstractMessageSender<T>
com.caucho.message.tourmaline.NautilusClientSender<T>
- All Implemented Interfaces:
- MessageSender<T>, java.lang.Iterable<T>, java.util.Collection<T>, java.util.concurrent.BlockingQueue<T>, java.util.Queue<T>
public class NautilusClientSender<T>
- extends AbstractMessageSender<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, 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, 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 |
getAddress
public java.lang.String getAddress()
offerMicros
protected boolean offerMicros(MessagePropertiesFactory<T> factory,
T value,
long timeoutMicros)
- Description copied from class:
AbstractMessageSender
- Offers a value to the queue.
- Specified by:
offerMicros
in class AbstractMessageSender<T>
getLastMessageId
public long getLastMessageId()
- Description copied from interface:
MessageSender
- Returns the most recently received message id for acknowledgement.
remainingCapacity
public int remainingCapacity()
- Specified by:
remainingCapacity
in interface java.util.concurrent.BlockingQueue<T>
- Overrides:
remainingCapacity
in class AbstractQueueSender<T>
close
public void close()
toString
public java.lang.String toString()
- Overrides:
toString
in class AbstractMessageSender<T>