com.caucho.message.common

Class BasicMessageReceiver<T>

java.lang.Object

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

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

All Implemented Interfaces:

MessageReceiver<T>, java.lang.Iterable<T>, java.util.Collection<T>, java.util.concurrent.BlockingQueue<T>, java.util.Queue<T>

Direct Known Subclasses:

NautilusClientReceiver

public class BasicMessageReceiver<T>
extends AbstractMessageReceiver<T>

basic message receiver includes a linked queue.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BasicMessageReceiver(MessageReceiverFactory factory)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getAddress()
long	getLastMessageId() Returns the last message id for client ack.
int	getPrefetch()
void	onBuild()
protected T	pollMicros(long timeoutMicros) Polls the queue with a timeout.
void	receiveEntry(T value)
java.lang.String	toString()
void	updateCredit(int credit)
protected void	updateFlow(int credit, long endpointSequence)
protected void	wake()

Methods inherited from class com.caucho.message.common.AbstractMessageReceiver

accepted, add, addAll, clear, contains, containsAll, drainTo, drainTo, element, isEmpty, iterator, modified, offer, offer, peek, poll, poll, put, rejected, released, 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 java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

BasicMessageReceiver

protected BasicMessageReceiver(MessageReceiverFactory factory)

Method Detail

getAddress

public java.lang.String getAddress()

getPrefetch

public int getPrefetch()

getLastMessageId

public long getLastMessageId()

Description copied from interface: MessageReceiver

Returns the last message id for client ack.

Specified by:

getLastMessageId in interface MessageReceiver<T>

Overrides:

getLastMessageId in class AbstractMessageReceiver<T>

onBuild

public void onBuild()

Overrides:

onBuild in class AbstractMessageReceiver<T>

pollMicros

protected T pollMicros(long timeoutMicros)

Description copied from class: AbstractMessageReceiver

Polls the queue with a timeout.

Specified by:

pollMicros in class AbstractMessageReceiver<T>

updateFlow

protected void updateFlow(int credit,
                          long endpointSequence)

updateCredit

public void updateCredit(int credit)

receiveEntry

public void receiveEntry(T value)

wake

protected void wake()

toString

public java.lang.String toString()

Overrides:

toString in class AbstractMessageReceiver<T>