public class ChannelContext extends Object
Modifier and Type | Class and Description |
---|---|
(package private) static class |
ChannelContext.Delivery |
Modifier and Type | Field and Description |
---|---|
(package private) Map<String,QueueShell> |
consumerQueues
Maps a consumer tag to a queue.
|
(package private) long |
consumerTagCounter
Id used to generate a channel-unique consumerTag.
|
(package private) List<ChannelContext.Delivery> |
deliveriesToAck
Keeps the deliveries waiting for an acknowledgment.
|
private long |
deliveryTagCounter
Id used to generate a channel-unique deliveryTag;
|
(package private) String |
lastQueueCreated
The name of the last queue created on this channel, used when queue name is
not specified on BasicGet or QueueBind.
|
(package private) int |
prefetchCount
The configured maximum prefetched message count. 0 means no limit.
|
(package private) List<PublishRequest> |
pubToCommit
The publish requests waiting the Tx.Commit command.
|
(package private) boolean |
transacted
Tells if the channel is in transacted mode.
|
Constructor and Description |
---|
ChannelContext() |
String lastQueueCreated
int prefetchCount
List<ChannelContext.Delivery> deliveriesToAck
Map<String,QueueShell> consumerQueues
boolean transacted
List<PublishRequest> pubToCommit
private long deliveryTagCounter
long consumerTagCounter
Copyright © 2013 ScalAgent D.T.. All Rights Reserved.