com.caucho.message.tourmaline
Class NautilusClientSender<T>

java.lang.Object
  extended by com.caucho.message.common.AbstractQueueSender<T>
      extended by com.caucho.message.common.AbstractMessageSender<T>
          extended by 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


Method Summary
 void close()
           
 java.lang.String getAddress()
           
 long getLastMessageId()
          Returns the most recently received message id for acknowledgement.
protected  boolean offerMicros(MessagePropertiesFactory<T> factory, T value, long timeoutMicros)
          Offers a value to the queue.
 int remainingCapacity()
           
 java.lang.String toString()
           
 
Methods inherited from class com.caucho.message.common.AbstractMessageSender
createMessageFactory, getSettleListener, getSettleMode, getUnsettledCount
 
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
 

Method Detail

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>