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) |