Package org.ow2.joram.mom.amqp
Class ChannelContext
- java.lang.Object
-
- org.ow2.joram.mom.amqp.ChannelContext
-
public class ChannelContext extends Object
Class used to hold all the contextual data relative to one channel.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static classChannelContext.Delivery
-
Field Summary
Fields Modifier and Type Field Description (package private) Map<String,QueueShell>consumerQueuesMaps a consumer tag to a queue.(package private) longconsumerTagCounterId used to generate a channel-unique consumerTag.(package private) List<ChannelContext.Delivery>deliveriesToAckKeeps the deliveries waiting for an acknowledgment.private longdeliveryTagCounterId used to generate a channel-unique deliveryTag;(package private) StringlastQueueCreatedThe name of the last queue created on this channel, used when queue name is not specified on BasicGet or QueueBind.(package private) intprefetchCountThe configured maximum prefetched message count. 0 means no limit.(package private) List<PublishRequest>pubToCommitThe publish requests waiting the Tx.Commit command.(package private) booleantransactedTells if the channel is in transacted mode.
-
Constructor Summary
Constructors Constructor Description ChannelContext()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longnextDeliveryTag()
-
-
-
Field Detail
-
lastQueueCreated
String lastQueueCreated
The name of the last queue created on this channel, used when queue name is not specified on BasicGet or QueueBind.
-
prefetchCount
int prefetchCount
The configured maximum prefetched message count. 0 means no limit.
-
deliveriesToAck
List<ChannelContext.Delivery> deliveriesToAck
Keeps the deliveries waiting for an acknowledgment.
-
consumerQueues
Map<String,QueueShell> consumerQueues
Maps a consumer tag to a queue. A Least Recently Used map is necessary to get new deliveries on a round-robin basis when an acknowledgment is received.
-
transacted
boolean transacted
Tells if the channel is in transacted mode.
-
pubToCommit
List<PublishRequest> pubToCommit
The publish requests waiting the Tx.Commit command.
-
deliveryTagCounter
private long deliveryTagCounter
Id used to generate a channel-unique deliveryTag;
-
consumerTagCounter
long consumerTagCounter
Id used to generate a channel-unique consumerTag.
-
-