Class RecoveryAwareChannelN

java.lang.Object

com.rabbitmq.client.impl.ShutdownNotifierComponent

com.rabbitmq.client.impl.AMQChannel

com.rabbitmq.client.impl.ChannelN

com.rabbitmq.client.impl.recovery.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

Nested Class Summary

Nested classes/interfaces inherited from class AMQChannel

AMQChannel.BlockingRpcContinuation<T>, AMQChannel.RpcContinuation, AMQChannel.SimpleBlockingRpcContinuation

Field Summary

Fields

Modifier and Type	Field	Description
private long	activeDeliveryTagOffset
private long	maxSeenDeliveryTag

Fields inherited from class ChannelN

metricsCollector

Fields inherited from class AMQChannel

_blockContent, _channelLock, _channelLockCondition, _rpcTimeout, NO_RPC_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
RecoveryAwareChannelN(AMQConnection connection, int channelNumber, ConsumerWorkService workService)	Construct a new channel on the given connection with the given channel number.
RecoveryAwareChannelN(AMQConnection connection, int channelNumber, ConsumerWorkService workService, MetricsCollector metricsCollector, ObservationCollector observationCollector)	Construct a new channel on the given connection with the given channel number.

Method Summary

Modifier and Type	Method	Description
void	basicAck(long deliveryTag, boolean multiple)	Public API - Public API - Acknowledge one or several received messages.
void	basicNack(long deliveryTag, boolean multiple, boolean requeue)	Public API - Public API - Reject one or several received messages.
void	basicReject(long deliveryTag, boolean requeue)	Public API - Public API - Reject a message.
long	getActiveDeliveryTagOffset()
long	getMaxSeenDeliveryTag()
(package private) void	inheritOffsetFrom(RecoveryAwareChannelN other)
private AMQImpl.Basic.Deliver	offsetDeliveryTag(AMQImpl.Basic.Deliver method)
protected void	processDelivery(Command command, AMQImpl.Basic.Deliver method)

Methods inherited from class ChannelN

abort, abort, addConfirmListener, addConfirmListener, addReturnListener, addReturnListener, asyncCompletableRpc, asyncRpc, basicCancel, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicGet, basicPublish, basicPublish, basicPublish, basicQos, basicQos, basicQos, basicRecover, basicRecover, clearConfirmListeners, clearReturnListeners, close, close, close, confirmSelect, consumerCount, enqueueRpc, exchangeBind, exchangeBind, exchangeBindNoWait, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclareNoWait, exchangeDeclareNoWait, exchangeDeclarePassive, exchangeDelete, exchangeDelete, exchangeDeleteNoWait, exchangeUnbind, exchangeUnbind, exchangeUnbindNoWait, getDefaultConsumer, getNextPublishSeqNo, markRpcFinished, messageCount, open, processAsync, processShutdownSignal, queueBind, queueBind, queueBindNoWait, queueDeclare, queueDeclare, queueDeclareNoWait, queueDeclarePassive, queueDelete, queueDelete, queueDeleteNoWait, queuePurge, queueUnbind, queueUnbind, removeConfirmListener, removeReturnListener, rpc, setDefaultConsumer, txCommit, txRollback, txSelect, waitForConfirms, waitForConfirms, waitForConfirmsOrDie, waitForConfirmsOrDie

Methods inherited from class AMQChannel

asyncRpc, connectionInfo, enqueueAsyncRpc, ensureIsOpen, exnWrappingAsyncRpc, exnWrappingRpc, getChannelNumber, getConnection, handleCompleteInboundCommand, handleFrame, isOutstandingRpc, nextOutstandingRpc, notifyOutstandingRpc, quiescingAsyncRpc, quiescingRpc, quiescingTransmit, quiescingTransmit, rpc, rpc, toString, transmit, transmit, wrap, wrap, wrapTimeoutException

Methods inherited from class ShutdownNotifierComponent

addShutdownListener, getCloseReason, isOpen, notifyListeners, removeShutdownListener, setShutdownCauseIfOpen

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface Channel

getChannelNumber, getConnection

Methods inherited from interface ShutdownNotifier

addShutdownListener, getCloseReason, isOpen, notifyListeners, removeShutdownListener

Field Details

maxSeenDeliveryTag

private volatile long maxSeenDeliveryTag

activeDeliveryTagOffset

private volatile long activeDeliveryTagOffset

Constructor Details

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,
 ObservationCollector observationCollector)

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

Method Details

processDelivery

protected void processDelivery(Command command,
 AMQImpl.Basic.Deliver method)

Overrides:

processDelivery in class ChannelN

offsetDeliveryTag

private AMQImpl.Basic.Deliver offsetDeliveryTag(AMQImpl.Basic.Deliver method)

basicAck

public void basicAck(long deliveryTag,
 boolean multiple)
              throws IOException

Description copied from class: ChannelN

Public API - Acknowledge one or several received messages. Supply the deliveryTag from the AMQP.Basic.GetOk or AMQP.Basic.Deliver method containing the received message being acknowledged.

Specified by:

basicAck in interface Channel

Overrides:

basicAck in class ChannelN

Parameters:

deliveryTag - the tag from the received AMQP.Basic.GetOk or AMQP.Basic.Deliver

multiple - true to acknowledge all messages up to and including the supplied delivery tag; false to acknowledge just the supplied delivery tag.

Throws:

IOException - if an error is encountered

See Also:

• AMQP.Basic.Ack

basicNack

public void basicNack(long deliveryTag,
 boolean multiple,
 boolean requeue)
               throws IOException

Description copied from class: ChannelN

Public API - Reject one or several received messages. Supply the deliveryTag from the AMQP.Basic.GetOk or AMQP.Basic.Deliver method containing the message to be rejected.

Specified by:

basicNack in interface Channel

Overrides:

basicNack in class ChannelN

Parameters:

deliveryTag - the tag from the received AMQP.Basic.GetOk or AMQP.Basic.Deliver

multiple - true to reject all messages up to and including the supplied delivery tag; false to reject just the supplied delivery tag.

requeue - true if the rejected message(s) should be requeued rather than discarded/dead-lettered

Throws:

IOException - if an error is encountered

See Also:

• AMQP.Basic.Nack

basicReject

public void basicReject(long deliveryTag,
 boolean requeue)
                 throws IOException

Description copied from class: ChannelN

Public API - Reject a message. Supply the deliveryTag from the AMQP.Basic.GetOk or AMQP.Basic.Deliver method containing the received message being rejected.

Specified by:

basicReject in interface Channel

Overrides:

basicReject in class ChannelN

Parameters:

deliveryTag - the tag from the received AMQP.Basic.GetOk or AMQP.Basic.Deliver

requeue - true if the rejected message should be requeued rather than discarded/dead-lettered

Throws:

IOException - if an error is encountered

See Also:

• AMQP.Basic.Reject

inheritOffsetFrom

void inheritOffsetFrom(RecoveryAwareChannelN other)

getMaxSeenDeliveryTag

public long getMaxSeenDeliveryTag()

getActiveDeliveryTagOffset

public long getActiveDeliveryTagOffset()