Class RecoveryAwareChannelN

  • All Implemented Interfaces:
    Channel, ShutdownNotifier, AutoCloseable

    public class RecoveryAwareChannelN
    extends ChannelN
    ChannelN modification that keeps track of delivery tags and avoids sending
    basic.ack
    ,
    basic.nack
    , and
    basic.reject
    for stale tags.
    Since:
    3.3.0
    • Constructor Detail

      • RecoveryAwareChannelN

        public RecoveryAwareChannelN​(AMQConnection connection,
                                     int channelNumber,
                                     ConsumerWorkService workService)
        Construct a new channel on the given connection with the given channel number. Usually not called directly - call Connection.createChannel instead.
        Parameters:
        connection - The connection associated with this channel
        channelNumber - The channel number to be associated with this channel
        workService - service for managing this channel's consumer callbacks
      • RecoveryAwareChannelN

        public RecoveryAwareChannelN​(AMQConnection connection,
                                     int channelNumber,
                                     ConsumerWorkService workService,
                                     MetricsCollector metricsCollector)
        Construct a new channel on the given connection with the given channel number. Usually not called directly - call Connection.createChannel instead.
        Parameters:
        connection - The connection associated with this channel
        channelNumber - The channel number to be associated with this channel
        workService - service for managing this channel's consumer callbacks
        metricsCollector - service for managing metrics