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

java.lang.Object
  extended by com.caucho.message.common.AbstractMessageReceiver<T>
      extended by 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
protected BasicMessageReceiver(MessageReceiverFactory factory)
           
 
Method Summary
 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
 

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>