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

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

Methods inherited from interface java.lang.Iterable

forEach

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.