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.
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 |
BasicMessageReceiver
protected BasicMessageReceiver(MessageReceiverFactory factory)
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>