Package | Description |
---|---|
com.caucho.amqp.client | |
com.caucho.amqp.common | |
com.caucho.amqp.io | |
com.caucho.amqp.server |
Modifier and Type | Class and Description |
---|---|
class |
AmqpClientReceiverLink
link session management
|
class |
AmqpClientSenderLink
link session management
|
Modifier and Type | Class and Description |
---|---|
class |
TransferSettleManager<L extends AmqpLink>
manages transfers and settlements.
|
Modifier and Type | Class and Description |
---|---|
class |
AmqpReceiverLink
link management
|
class |
AmqpSenderLink
link management
|
Modifier and Type | Method and Description |
---|---|
AmqpLink |
AmqpSession.detachOutgoingLink(int handle) |
AmqpLink |
DeliveryNode.getLink() |
AmqpLink |
AmqpSession.getOutgoingLink(int handle) |
Modifier and Type | Method and Description |
---|---|
void |
AmqpConnectionHandler.closeSender(AmqpLink link) |
void |
AmqpConnectionHandler.flow(AmqpLink link,
long deliveryCount,
int credit) |
Modifier and Type | Method and Description |
---|---|
void |
AmqpConnectionWriter.attachReceiver(AmqpSession session,
AmqpLink link,
DistributionMode distMode,
SettleMode settleMode) |
void |
AmqpConnectionWriter.attachReply(AmqpSession session,
AmqpLink link) |
void |
AmqpConnectionWriter.attachSender(AmqpSession session,
AmqpLink link,
SettleMode settleMode) |
void |
AmqpConnectionWriter.sendFlow(AmqpSession session,
AmqpLink link,
long deliveryCount,
int credit) |
Modifier and Type | Class and Description |
---|---|
class |
AmqpServerReceiverLink
link session management
|
class |
AmqpServerSenderLink
link session management
|