com.caucho.message.tourmaline
Class NautilusClientReceiver<T>

java.lang.Object
  extended by com.caucho.message.common.AbstractMessageReceiver<T>
      extended by com.caucho.message.common.BasicMessageReceiver<T>
          extended by com.caucho.message.tourmaline.NautilusClientReceiver<T>
All Implemented Interfaces:
MessageReceiver<T>, java.lang.Iterable<T>, java.util.Collection<T>, java.util.concurrent.BlockingQueue<T>, java.util.Queue<T>

public class NautilusClientReceiver<T>
extends BasicMessageReceiver<T>

local connection to the message store


Method Summary
protected  void updateFlow(int credit, long endpointSequence)
           
 
Methods inherited from class com.caucho.message.common.BasicMessageReceiver
getAddress, getLastMessageId, getPrefetch, onBuild, pollMicros, receiveEntry, toString, updateCredit, 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
 

Method Detail

updateFlow

protected void updateFlow(int credit,
                          long endpointSequence)
Overrides:
updateFlow in class BasicMessageReceiver<T>