com.caucho.message
Interface MessageSender<T>

All Superinterfaces:
java.util.concurrent.BlockingQueue<T>, java.util.Collection<T>, java.lang.Iterable<T>, java.util.Queue<T>
All Known Subinterfaces:
AmqpSender<T>
All Known Implementing Classes:
AbstractMessageSender, LocalSender, NautilusClientSender

public interface MessageSender<T>
extends java.util.concurrent.BlockingQueue<T>

message sender


Method Summary
 void close()
           
 MessagePropertiesFactory<T> createMessageFactory()
           
 long getLastMessageId()
          Returns the most recently received message id for acknowledgement.
 MessageSettleListener getSettleListener()
           
 SettleMode getSettleMode()
          Auto-settle sends messages without waiting for confirmation from the broker.
 int getUnsettledCount()
           
 
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
 

Method Detail

getSettleMode

SettleMode getSettleMode()
Auto-settle sends messages without waiting for confirmation from the broker.


getLastMessageId

long getLastMessageId()
Returns the most recently received message id for acknowledgement.


getSettleListener

MessageSettleListener getSettleListener()

getUnsettledCount

int getUnsettledCount()

createMessageFactory

MessagePropertiesFactory<T> createMessageFactory()

close

void close()