| Package | Description | 
|---|---|
| com.caucho.amqp | |
| com.caucho.message | |
| com.caucho.message.common | |
| com.caucho.message.local | |
| com.caucho.message.tourmaline | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
AmqpReceiver<T>
AMQP client receiver 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MessageReceiver<?> | 
MessageReceiverFactory.build()  | 
MessageReceiver<?> | 
MessageConnection.createReceiver(java.lang.String queueName)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
MessageReceiverListener.onMessage(long mid,
         T value,
         MessageReceiver<T> receiver)
Receives the next message. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractMessageReceiver<T>
abstract receiver from a message store 
 | 
class  | 
BasicMessageReceiver<T>
basic message receiver includes a linked queue. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
abstract MessageReceiver<?> | 
AbstractMessageReceiverFactory.build()  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
LocalReceiver<T>
local connection to the message store 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MessageReceiver<?> | 
LocalReceiverFactory.build()  | 
MessageReceiver<?> | 
LocalConnectionImpl.createReceiver(java.lang.String queueName)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
NautilusClientReceiver<T>
local connection to the message store 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MessageReceiver<?> | 
NautilusClientConnection.createReceiver(java.lang.String queueName)  |