com.caucho.message.local
Class LocalReceiver<T>

java.lang.Object
  extended by com.caucho.message.common.AbstractMessageReceiver<T>
      extended by 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
 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
 

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>