Package | Description |
---|---|
com.caucho.amqp | |
com.caucho.message | |
com.caucho.message.common | |
com.caucho.message.local |
Modifier and Type | Interface and Description |
---|---|
interface |
AmqpReceiverFactory
AMQP client receiver factor
|
Modifier and Type | Method and Description |
---|---|
MessageReceiverFactory |
MessageConnection.createReceiverFactory() |
MessageReceiverFactory |
MessageReceiverFactory.setAddress(java.lang.String address) |
MessageReceiverFactory |
MessageReceiverFactory.setDistributionMode(DistributionMode mode) |
MessageReceiverFactory |
MessageReceiverFactory.setListener(MessageReceiverListener<?> listener) |
MessageReceiverFactory |
MessageReceiverFactory.setMessageDecoder(MessageDecoder<?> decoder) |
MessageReceiverFactory |
MessageReceiverFactory.setPrefetch(int prefetch) |
MessageReceiverFactory |
MessageReceiverFactory.setSettleMode(SettleMode settleMode) |
MessageReceiverFactory |
MessageReceiverFactory.setSettleTime(SettleTime settleTime) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageReceiverFactory
local connection to the message store
|
Modifier and Type | Method and Description |
---|---|
MessageReceiverFactory |
AbstractMessageReceiverFactory.setAddress(java.lang.String address) |
MessageReceiverFactory |
AbstractMessageReceiverFactory.setDistributionMode(DistributionMode mode) |
MessageReceiverFactory |
AbstractMessageReceiverFactory.setListener(MessageReceiverListener<?> listener) |
MessageReceiverFactory |
AbstractMessageReceiverFactory.setMessageDecoder(MessageDecoder<?> decoder) |
MessageReceiverFactory |
AbstractMessageReceiverFactory.setPrefetch(int prefetch) |
MessageReceiverFactory |
AbstractMessageReceiverFactory.setSettleMode(SettleMode settleMode) |
MessageReceiverFactory |
AbstractMessageReceiverFactory.setSettleTime(SettleTime settleTime) |
Constructor and Description |
---|
BasicMessageReceiver(MessageReceiverFactory factory) |
Modifier and Type | Class and Description |
---|---|
class |
LocalReceiverFactory
factory to create local receivers.
|