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

Modifier and Type	Method and Description
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, parallelStream, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

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()