com.caucho.message.tourmaline

Class NautilusClientReceiver<T>

java.lang.Object

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

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

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

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

Methods inherited from interface java.lang.Iterable

forEach

Method Detail

updateFlow

protected void updateFlow(int credit,
                          long endpointSequence)

Overrides:

updateFlow in class BasicMessageReceiver<T>