Class ChannelContext


  • public class ChannelContext
    extends Object
    Class used to hold all the contextual data relative to one channel.
    • 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.
      • 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.
    • Constructor Detail

      • ChannelContext

        public ChannelContext()
    • Method Detail

      • nextDeliveryTag

        public long nextDeliveryTag()