com.caucho.message.common
Class AbstractMessageSender<T>

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


Constructor Summary
protected AbstractMessageSender(MessageSenderFactory factory)
           
 
Method Summary
 MessagePropertiesFactory<T> createMessageFactory()
           
 MessageSettleListener getSettleListener()
           
 SettleMode getSettleMode()
          Auto-settle sends messages without waiting for confirmation from the broker.
 int getUnsettledCount()
           
protected abstract  boolean offerMicros(MessagePropertiesFactory<T> factory, T value, long timeoutMicros)
          Offers a value to the queue.
 java.lang.String toString()
           
 
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 com.caucho.message.MessageSender
close, getLastMessageId
 
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
 

Constructor Detail

AbstractMessageSender

protected AbstractMessageSender(MessageSenderFactory factory)
Method Detail

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>