com.caucho.message.tourmaline

Class NautilusClientSender<T>

java.lang.Object

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

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

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

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

Methods inherited from interface java.lang.Iterable

forEach

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>