Package | Description |
---|---|
com.caucho.amqp.client | |
com.caucho.amqp.common | |
com.caucho.amqp.io | |
com.caucho.amqp.server | |
com.caucho.message | |
com.caucho.message.common | |
com.caucho.message.local |
Modifier and Type | Method and Description |
---|---|
AmqpSenderLink |
AmqpClientConnectionImpl.createSenderLink(java.lang.String name,
java.lang.String address,
DistributionMode distMode,
SettleMode settleMode,
java.util.Map<java.lang.String,java.lang.Object> nodeProperties) |
Modifier and Type | Method and Description |
---|---|
long |
TransferSettleManager.addDelivery(L link,
long messageId,
SettleMode settleMode) |
boolean |
AmqpSession.addReceiverLink(AmqpReceiverLink link,
DistributionMode distMode,
SettleMode settleMode) |
boolean |
AmqpSession.addSenderLink(AmqpSenderLink link,
SettleMode settleMode) |
AmqpSenderLink |
AmqpLinkFactory.createSenderLink(java.lang.String name,
java.lang.String address,
DistributionMode distMode,
SettleMode settleMode,
java.util.Map<java.lang.String,java.lang.Object> sourceProperties) |
void |
AmqpSession.transfer(AmqpSenderLink link,
long mid,
SettleMode settleMode,
java.io.InputStream is)
Sends a message to the network.
|
void |
AmqpSenderLink.transfer(long mid,
SettleMode settleMode,
java.io.InputStream is) |
Modifier and Type | Method and Description |
---|---|
void |
AmqpConnectionWriter.attachReceiver(AmqpSession session,
AmqpLink link,
DistributionMode distMode,
SettleMode settleMode) |
void |
AmqpConnectionWriter.attachSender(AmqpSession session,
AmqpLink link,
SettleMode settleMode) |
void |
AmqpConnectionWriter.transfer(AmqpSession session,
AmqpSenderLink link,
long deliveryId,
SettleMode settleMode,
java.io.InputStream is)
Transfers a message.
|
Constructor and Description |
---|
AmqpServerSenderLink(java.lang.String name,
java.lang.String address,
SettleMode settleMode) |
Modifier and Type | Method and Description |
---|---|
SettleMode |
MessageSender.getSettleMode()
Auto-settle sends messages without waiting for confirmation
from the broker.
|
SettleMode |
MessageSenderFactory.getSettleMode() |
SettleMode |
MessageReceiverFactory.getSettleMode() |
static SettleMode |
SettleMode.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static SettleMode[] |
SettleMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
MessageSenderFactory |
MessageSenderFactory.setSettleMode(SettleMode settleMode) |
MessageReceiverFactory |
MessageReceiverFactory.setSettleMode(SettleMode settleMode) |
Modifier and Type | Method and Description |
---|---|
SettleMode |
AbstractMessageSender.getSettleMode() |
SettleMode |
AbstractMessageReceiverFactory.getSettleMode() |
SettleMode |
AbstractMessageSenderFactory.getSettleMode() |
Modifier and Type | Method and Description |
---|---|
MessageReceiverFactory |
AbstractMessageReceiverFactory.setSettleMode(SettleMode settleMode) |
AbstractMessageSenderFactory |
AbstractMessageSenderFactory.setSettleMode(SettleMode settleMode) |
Modifier and Type | Method and Description |
---|---|
LocalReceiverFactory |
LocalReceiverFactory.setSettleMode(SettleMode settleMode) |