com.caucho.message
Interface MessageReceiver<T>

All Superinterfaces:
java.util.concurrent.BlockingQueue<T>, java.util.Collection<T>, java.lang.Iterable<T>, java.util.Queue<T>
All Known Subinterfaces:
AmqpReceiver<T>
All Known Implementing Classes:
AbstractMessageReceiver, BasicMessageReceiver, LocalReceiver, NautilusClientReceiver

public interface MessageReceiver<T>
extends java.util.concurrent.BlockingQueue<T>

message receiver


Method Summary
 void accepted(long mid)
          Accept the last message.
 long getLastMessageId()
          Returns the last message id for client ack.
 void modified(long mid, boolean isFailed, boolean isUndeliverableHere)
          Returns the message as modified.
 void rejected(long mid, java.lang.String errorMessage)
          Reject the last message.
 void released(long mid)
          Release the last message.
 
Methods inherited from interface java.util.concurrent.BlockingQueue
add, contains, drainTo, drainTo, offer, offer, poll, put, remainingCapacity, remove, take
 
Methods inherited from interface java.util.Queue
element, peek, poll, remove
 
Methods inherited from interface java.util.Collection
addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, removeAll, retainAll, size, toArray, toArray
 

Method Detail

getLastMessageId

long getLastMessageId()
Returns the last message id for client ack.


accepted

void accepted(long mid)
Accept the last message.


rejected

void rejected(long mid,
              java.lang.String errorMessage)
Reject the last message.


released

void released(long mid)
Release the last message.


modified

void modified(long mid,
              boolean isFailed,
              boolean isUndeliverableHere)
Returns the message as modified.