com.caucho.message.local

Class LocalReceiver<T>

java.lang.Object

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

com.caucho.message.local.LocalReceiver<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 LocalReceiver<T>
extends AbstractMessageReceiver<T>

local connection to the message store

Method Summary

Modifier and Type	Method and Description
java.lang.String	getAddress()
protected T	pollMicros(long timeoutMicros) Polls the queue with a timeout.
java.lang.String	toString()

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

accepted, add, addAll, clear, contains, containsAll, drainTo, drainTo, element, getLastMessageId, isEmpty, iterator, modified, offer, offer, onBuild, 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

getAddress

public java.lang.String getAddress()

pollMicros

protected T pollMicros(long timeoutMicros)

Description copied from class: AbstractMessageReceiver

Polls the queue with a timeout.

Specified by:

pollMicros in class AbstractMessageReceiver<T>

toString

public java.lang.String toString()

Overrides:

toString in class AbstractMessageReceiver<T>