com.caucho.message.common

Class AbstractMessageSender<T>

java.lang.Object

com.caucho.message.common.AbstractQueueSender<T>

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

Constructors

Modifier	Constructor and Description
protected	AbstractMessageSender(MessageSenderFactory factory)

Method Summary

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

Methods inherited from interface java.lang.Iterable

forEach

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>