Class AutorecoveringConnection

java.lang.Object

com.rabbitmq.client.impl.recovery.AutorecoveringConnection

All Implemented Interfaces:

Connection, NetworkConnection, Recoverable, RecoverableConnection, ShutdownNotifier, Closeable, AutoCloseable

public class AutorecoveringConnection
extends Object
implements RecoverableConnection, NetworkConnection

Connection implementation that performs automatic recovery when connection shutdown is not initiated by the application (e.g. due to an I/O exception). Topology (exchanges, queues, bindings, and consumers) can be (and by default is) recovered as well, in this order:

1. Exchanges
2. Queues
3. Bindings (both queue and exchange-to-exchange)
4. Consumers

Since:

3.3.0

See Also:

• Connection
• Recoverable
• ConnectionFactory.setAutomaticRecoveryEnabled(boolean)
• ConnectionFactory.setTopologyRecoveryEnabled(boolean)

Field Summary

Fields

Modifier and Type	Field	Description
private final List<BlockedListener>	blockedListeners
private final RecoveryAwareAMQConnectionFactory	cf
private final Map<Integer, AutorecoveringChannel>	channels
private final Predicate<ShutdownSignalException>	connectionRecoveryTriggeringCondition
private final List<ConsumerRecoveryListener>	consumerRecoveryListeners
private final Map<String, RecordedConsumer>	consumers
static final Predicate<ShutdownSignalException>	DEFAULT_CONNECTION_RECOVERY_TRIGGERING_CONDITION
private RecoveryAwareAMQConnection	delegate
private static final org.slf4j.Logger	LOGGER
private boolean	manuallyClosed
private final ConnectionParams	params
private final List<QueueRecoveryListener>	queueRecoveryListeners
private final List<RecordedBinding>	recordedBindings
private final Map<String, RecordedExchange>	recordedExchanges
private final Map<String, RecordedQueue>	recordedQueues
private final RecoveredQueueNameSupplier	recoveredQueueNameSupplier
private final List<RecoveryListener>	recoveryListeners
private final Object	recoveryLock
private final RetryHandler	retryHandler
private final List<ShutdownListener>	shutdownHooks
private final TopologyRecoveryFilter	topologyRecoveryFilter

Constructor Summary

Constructors

Constructor	Description
AutorecoveringConnection(ConnectionParams params, FrameHandlerFactory f, AddressResolver addressResolver)
AutorecoveringConnection(ConnectionParams params, FrameHandlerFactory f, AddressResolver addressResolver, MetricsCollector metricsCollector, ObservationCollector observationCollector)
AutorecoveringConnection(ConnectionParams params, FrameHandlerFactory f, List<Address> addrs)

Method Summary

Modifier and Type	Method	Description
void	abort()	Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
void	abort(int timeout)	Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
void	abort(int closeCode, String closeMessage)	Abort this connection and all its channels.
void	abort(int closeCode, String closeMessage, int timeout)	Abort this connection and all its channels.
private void	addAutomaticRecoveryListener(RecoveryAwareAMQConnection newConn)
BlockedListener	addBlockedListener(BlockedCallback blockedCallback, UnblockedCallback unblockedCallback)	Add a lambda-based BlockedListener.
void	addBlockedListener(BlockedListener listener)	Add a BlockedListener.
void	addConsumerRecoveryListener(ConsumerRecoveryListener listener)	Not part of the public API.
void	addQueueRecoveryListener(QueueRecoveryListener listener)	Not part of the public API.
void	addRecoveryListener(RecoveryListener listener)	Adds the recovery listener
void	addShutdownListener(ShutdownListener listener)	Add shutdown listener.
private void	beginAutomaticRecovery()
void	clearBlockedListeners()	Remove all BlockedListeners.
void	close()	Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
void	close(int timeout)	Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
void	close(int closeCode, String closeMessage)	Close this connection and all its channels.
void	close(int closeCode, String closeMessage, int timeout)	Close this connection and all its channels.
Channel	createChannel()	Create a new channel, using an internally allocated channel number.
Channel	createChannel(int channelNumber)	Create a new channel, using the specified channel number if possible.
(package private) RecordedConsumer	deleteRecordedConsumer(String consumerTag)
(package private) void	deleteRecordedExchange(String exchange)
(package private) boolean	deleteRecordedExchangeBinding(AutorecoveringChannel ch, String destination, String source, String routingKey, Map<String,Object> arguments)
(package private) void	deleteRecordedQueue(String queue)
(package private) boolean	deleteRecordedQueueBinding(AutorecoveringChannel ch, String queue, String exchange, String routingKey, Map<String,Object> arguments)
void	excludeQueueFromRecovery(String queue, boolean ifUnused)	Exclude the queue from the list of queues to recover after connection failure.
InetAddress	getAddress()	Retrieve the host.
int	getChannelMax()	Get the negotiated maximum channel number.
Map<String,Object>	getClientProperties()	Get a copy of the map of client properties sent to the server
String	getClientProvidedName()	Returns client-provided connection name, if any.
ShutdownSignalException	getCloseReason()	Get the shutdown reason object
AMQConnection	getDelegate()	Not supposed to be used outside of automated tests.
ExceptionHandler	getExceptionHandler()	Get the exception handler.
int	getFrameMax()	Get the negotiated maximum frame size.
int	getHeartbeat()	Get the negotiated heartbeat interval.
String	getId()	Public API - Returns a unique ID for this connection.
InetAddress	getLocalAddress()	Retrieve the local host.
int	getLocalPort()	Retrieve the local port number.
int	getPort()	Retrieve the port number.
List<RecordedBinding>	getRecordedBindings()
Map<String, RecordedConsumer>	getRecordedConsumers()
Map<String, RecordedExchange>	getRecordedExchanges()
Map<String, RecordedQueue>	getRecordedQueues()
(package private) RecoveredQueueNameSupplier	getRecoveredQueueNameSupplier()
Map<String,Object>	getServerProperties()	Retrieve the server properties.
private <E extends RecordedEntity> List<Callable<Object>>	groupEntitiesByChannel(Collection<E> entities)
(package private) boolean	hasMoreConsumersOnQueue(Collection<RecordedConsumer> consumers, String queue)
(package private) boolean	hasMoreDestinationsBoundToExchange(List<RecordedBinding> bindings, String exchange)
void	init()	Private API.
private void	internalRecoverConsumer(String tag, RecordedConsumer consumer, boolean retry)
private void	internalRecoverQueue(String oldName, RecordedQueue q, boolean retry)
boolean	isOpen()	Determine whether the component is currently open.
private static TopologyRecoveryFilter	letAllPassFilter()
(package private) void	maybeDeleteRecordedAutoDeleteExchange(String exchange)
(package private) void	maybeDeleteRecordedAutoDeleteQueue(String queue)
void	notifyListeners()	Protected API - notify the listeners attached to the component
private void	notifyRecoveryListenersComplete()
private void	notifyRecoveryListenersStarted()
private void	notifyTopologyRecoveryListenersStarted()
private void	propagateQueueNameChangeToBindings(String oldName, String newName)
private void	propagateQueueNameChangeToConsumers(String oldName, String newName)
(package private) void	recordConsumer(String result, RecordedConsumer consumer)
(package private) void	recordExchange(String exchange, RecordedExchange x)
(package private) void	recordExchangeBinding(AutorecoveringChannel ch, String destination, String source, String routingKey, Map<String,Object> arguments)
(package private) void	recordQueue(AMQP.Queue.DeclareOk ok, RecordedQueue q)
(package private) void	recordQueue(String queue, RecordedQueue meta)
(package private) void	recordQueueBinding(AutorecoveringChannel ch, String queue, String exchange, String routingKey, Map<String,Object> arguments)
void	recoverBinding(RecordedBinding b, boolean retry)
private void	recoverBlockedListeners(RecoveryAwareAMQConnection newConn)
void	recoverChannel(AutorecoveringChannel channel)
void	recoverChannelAndTopology(AutorecoveringChannel channel)	Recover a closed channel and all topology (i.e.
private void	recoverChannels(RecoveryAwareAMQConnection newConn)
private RecoveryAwareAMQConnection	recoverConnection()
(package private) void	recoverConsumer(String tag, RecordedConsumer consumer)	Recover the consumer.
void	recoverConsumer(String tag, RecordedConsumer consumer, boolean retry)	Recover the consumer.
private void	recoverEntitiesAsynchronously(ExecutorService executor, Collection<? extends RecordedEntity> recordedEntities)
void	recoverExchange(RecordedExchange x, boolean retry)
(package private) void	recoverQueue(String oldName, RecordedQueue q)	Recover the queue.
void	recoverQueue(String oldName, RecordedQueue q, boolean retry)	Recover the queue.
private void	recoverShutdownListeners(RecoveryAwareAMQConnection newConn)
private void	recoverTopology(ExecutorService executor)
(package private) void	registerChannel(AutorecoveringChannel channel)
(package private) Set<RecordedBinding>	removeBindingsWithDestination(String s)
boolean	removeBlockedListener(BlockedListener listener)	Remove a BlockedListener.
void	removeConsumerRecoveryListener(ConsumerRecoveryListener listener)
void	removeQueueRecoveryListener(QueueRecoveryListener listener)
void	removeRecoveryListener(RecoveryListener listener)	Removes the recovery listener
void	removeShutdownListener(ShutdownListener listener)	Remove shutdown listener for the component.
void	setId(String id)	Public API - Sets a unique ID for this connection.
private void	setupErrorOnWriteListenerForPotentialRecovery()
protected boolean	shouldTriggerConnectionRecovery(ShutdownSignalException cause)
String	toString()
(package private) void	unregisterChannel(AutorecoveringChannel channel)
private Channel	wrapChannel(RecoveryAwareChannelN delegateChannel)	Creates a recovering channel from a regular channel and registers it.
private <T> RetryResult	wrapRetryIfNecessary(RecordedEntity entity, Callable<T> recoveryAction)

Methods inherited from class Object

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

Methods inherited from interface Connection

openChannel, openChannel

Field Details

DEFAULT_CONNECTION_RECOVERY_TRIGGERING_CONDITION

public static final Predicate<ShutdownSignalException> DEFAULT_CONNECTION_RECOVERY_TRIGGERING_CONDITION

LOGGER

private static final org.slf4j.Logger LOGGER

cf

private final RecoveryAwareAMQConnectionFactory cf

channels

private final Map<Integer, AutorecoveringChannel> channels

params

private final ConnectionParams params

delegate

private volatile RecoveryAwareAMQConnection delegate

shutdownHooks

private final List<ShutdownListener> shutdownHooks

recoveryListeners

private final List<RecoveryListener> recoveryListeners

blockedListeners

private final List<BlockedListener> blockedListeners

recordedQueues

private final Map<String, RecordedQueue> recordedQueues

recordedBindings

private final List<RecordedBinding> recordedBindings

recordedExchanges

private final Map<String, RecordedExchange> recordedExchanges

consumers

private final Map<String, RecordedConsumer> consumers

consumerRecoveryListeners

private final List<ConsumerRecoveryListener> consumerRecoveryListeners

queueRecoveryListeners

private final List<QueueRecoveryListener> queueRecoveryListeners

topologyRecoveryFilter

private final TopologyRecoveryFilter topologyRecoveryFilter

manuallyClosed

private volatile boolean manuallyClosed

recoveryLock

private final Object recoveryLock

connectionRecoveryTriggeringCondition

private final Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition

retryHandler

private final RetryHandler retryHandler

recoveredQueueNameSupplier

private final RecoveredQueueNameSupplier recoveredQueueNameSupplier

Constructor Details

AutorecoveringConnection

public AutorecoveringConnection(ConnectionParams params,
 FrameHandlerFactory f,
 List<Address> addrs)

AutorecoveringConnection

public AutorecoveringConnection(ConnectionParams params,
 FrameHandlerFactory f,
 AddressResolver addressResolver)

AutorecoveringConnection

public AutorecoveringConnection(ConnectionParams params,
 FrameHandlerFactory f,
 AddressResolver addressResolver,
 MetricsCollector metricsCollector,
 ObservationCollector observationCollector)

Method Details

setupErrorOnWriteListenerForPotentialRecovery

private void setupErrorOnWriteListenerForPotentialRecovery()

letAllPassFilter

private static TopologyRecoveryFilter letAllPassFilter()

init

public void init()
          throws IOException,
TimeoutException

Private API.

Throws:

IOException

TimeoutException

See Also:

• ConnectionFactory.newConnection(java.util.concurrent.ExecutorService)

createChannel

public Channel createChannel()
                      throws IOException

Description copied from interface: Connection

Create a new channel, using an internally allocated channel number. If automatic connection recovery is enabled, the channel returned by this method will be Recoverable.

Use Connection.openChannel() if you want to use an Optional to deal with a value.

Specified by:

createChannel in interface Connection

Returns:

a new channel descriptor, or null if none is available

Throws:

IOException - if an I/O problem is encountered

See Also:

• Connection.createChannel()

createChannel

public Channel createChannel(int channelNumber)
                      throws IOException

Description copied from interface: Connection

Create a new channel, using the specified channel number if possible.

Use Connection.openChannel(int) if you want to use an Optional to deal with a value.

Specified by:

createChannel in interface Connection

Parameters:

channelNumber - the channel number to allocate

Returns:

a new channel descriptor, or null if this channel number is already in use

Throws:

IOException - if an I/O problem is encountered

See Also:

• Connection.createChannel(int)

wrapChannel

private Channel wrapChannel(RecoveryAwareChannelN delegateChannel)

Creates a recovering channel from a regular channel and registers it. If the regular channel cannot be created (e.g. too many channels are open already), returns null.

Parameters:

delegateChannel - Channel to wrap.

Returns:

Recovering channel.

registerChannel

void registerChannel(AutorecoveringChannel channel)

unregisterChannel

void unregisterChannel(AutorecoveringChannel channel)

getServerProperties

public Map<String,Object> getServerProperties()

Description copied from interface: Connection

Retrieve the server properties.

Specified by:

getServerProperties in interface Connection

Returns:

a map of the server properties. This typically includes the product name and version of the server.

See Also:

• Connection.getServerProperties()

getClientProperties

public Map<String,Object> getClientProperties()

Description copied from interface: Connection

Get a copy of the map of client properties sent to the server

Specified by:

getClientProperties in interface Connection

Returns:

a copy of the map of client properties

See Also:

• Connection.getClientProperties()

getClientProvidedName

public String getClientProvidedName()

Description copied from interface: Connection

Returns client-provided connection name, if any. Note that the value returned does not uniquely identify a connection and cannot be used as a connection identifier in HTTP API requests.

Specified by:

getClientProvidedName in interface Connection

Returns:

client-provided connection name, if any

See Also:

• Connection.getClientProvidedName()
• ConnectionFactory.newConnection(Address[], String)
• ConnectionFactory.newConnection(ExecutorService, Address[], String)

getFrameMax

public int getFrameMax()

Description copied from interface: Connection

Get the negotiated maximum frame size.

Specified by:

getFrameMax in interface Connection

Returns:

the maximum frame size, in octets; zero if unlimited

See Also:

• Connection.getFrameMax()

getHeartbeat

public int getHeartbeat()

Description copied from interface: Connection

Get the negotiated heartbeat interval.

Specified by:

getHeartbeat in interface Connection

Returns:

the heartbeat interval, in seconds; zero if none

See Also:

• Connection.getHeartbeat()

getChannelMax

public int getChannelMax()

Description copied from interface: Connection

Get the negotiated maximum channel number. Usable channel numbers range from 1 to this number, inclusive.

Specified by:

getChannelMax in interface Connection

Returns:

the maximum channel number permitted for this connection.

See Also:

• Connection.getChannelMax()

isOpen

public boolean isOpen()

Description copied from interface: ShutdownNotifier

Determine whether the component is currently open. Will return false if we are currently closing. Checking this method should be only for information, because of the race conditions - state can change after the call. Instead just execute and try to catch ShutdownSignalException and IOException

Specified by:

isOpen in interface ShutdownNotifier

Returns:

true when component is open, false otherwise

See Also:

• ShutdownNotifier.isOpen()

close

public void close()
           throws IOException

Description copied from interface: Connection

Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'. Waits for all the close operations to complete.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Connection

Throws:

IOException - if an I/O problem is encountered

See Also:

• Connection.close()

close

public void close(int timeout)
           throws IOException

Description copied from interface: Connection

Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'. This method behaves in a similar way as Connection.close(), with the only difference that it waits with a provided timeout for all the close operations to complete. When timeout is reached the socket is forced to close.

Specified by:

close in interface Connection

Parameters:

timeout - timeout (in milliseconds) for completing all the close-related operations, use -1 for infinity

Throws:

IOException - if an I/O problem is encountered

See Also:

• Connection.close(int)

close

public void close(int closeCode,
 String closeMessage,
 int timeout)
           throws IOException

Description copied from interface: Connection

Close this connection and all its channels. Waits with the given timeout for all the close operations to complete. When timeout is reached the socket is forced to close.

Specified by:

close in interface Connection

Parameters:

closeCode - the close code (See under "Reply Codes" in the AMQP specification)

closeMessage - a message indicating the reason for closing the connection

timeout - timeout (in milliseconds) for completing all the close-related operations, use -1 for infinity

Throws:

IOException - if an I/O problem is encountered

See Also:

• Connection.close(int, String, int)

abort

public void abort()

Description copied from interface: Connection

Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'. Forces the connection to close. Any encountered exceptions in the close operations are silently discarded.

Specified by:

abort in interface Connection

See Also:

• Connection.abort()

abort

public void abort(int closeCode,
 String closeMessage,
 int timeout)

Description copied from interface: Connection

Abort this connection and all its channels. Forces the connection to close and waits with the given timeout for all the close operations to complete. When timeout is reached the socket is forced to close. Any encountered exceptions in the close operations are silently discarded.

Specified by:

abort in interface Connection

Parameters:

closeCode - the close code (See under "Reply Codes" in the AMQP specification)

closeMessage - a message indicating the reason for closing the connection

timeout - timeout (in milliseconds) for completing all the close-related operations, use -1 for infinity

See Also:

• Connection.abort(int, String, int)

abort

public void abort(int closeCode,
 String closeMessage)

Description copied from interface: Connection

Abort this connection and all its channels. Forces the connection to close and waits for all the close operations to complete. Any encountered exceptions in the close operations are silently discarded.

Specified by:

abort in interface Connection

Parameters:

closeCode - the close code (See under "Reply Codes" in the AMQP specification)

closeMessage - a message indicating the reason for closing the connection

See Also:

• Connection.abort(int, String)

abort

public void abort(int timeout)

Description copied from interface: Connection

Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'. This method behaves in a similar way as Connection.abort(), with the only difference that it waits with a provided timeout for all the close operations to complete. When timeout is reached the socket is forced to close.

Specified by:

abort in interface Connection

Parameters:

timeout - timeout (in milliseconds) for completing all the close-related operations, use -1 for infinity

See Also:

• Connection.abort(int)

getDelegate

public AMQConnection getDelegate()

Not supposed to be used outside of automated tests.

getCloseReason

public ShutdownSignalException getCloseReason()

Description copied from interface: ShutdownNotifier

Get the shutdown reason object

Specified by:

getCloseReason in interface ShutdownNotifier

Returns:

ShutdownSignalException if component is closed, null otherwise

See Also:

• ShutdownNotifier.getCloseReason()

addBlockedListener

public void addBlockedListener(BlockedListener listener)

Description copied from interface: Connection

Add a BlockedListener.

Specified by:

addBlockedListener in interface Connection

Parameters:

listener - the listener to add

See Also:

• ShutdownNotifier.addShutdownListener(com.rabbitmq.client.ShutdownListener)

addBlockedListener

public BlockedListener addBlockedListener(BlockedCallback blockedCallback,
 UnblockedCallback unblockedCallback)

Description copied from interface: Connection

Add a lambda-based BlockedListener.

Specified by:

addBlockedListener in interface Connection

Parameters:

blockedCallback - the callback when the connection is blocked

unblockedCallback - the callback when the connection is unblocked

Returns:

the listener that wraps the callback

See Also:

• BlockedListener
• BlockedCallback
• UnblockedCallback

removeBlockedListener

public boolean removeBlockedListener(BlockedListener listener)

Description copied from interface: Connection

Remove a BlockedListener.

Specified by:

removeBlockedListener in interface Connection

Parameters:

listener - the listener to remove

Returns:

true if the listener was found and removed, false otherwise

See Also:

• Connection.removeBlockedListener(com.rabbitmq.client.BlockedListener)

clearBlockedListeners

public void clearBlockedListeners()

Description copied from interface: Connection

Remove all BlockedListeners.

Specified by:

clearBlockedListeners in interface Connection

See Also:

• Connection.clearBlockedListeners()

close

public void close(int closeCode,
 String closeMessage)
           throws IOException

Description copied from interface: Connection

Close this connection and all its channels. Waits for all the close operations to complete.

Specified by:

close in interface Connection

Parameters:

closeCode - the close code (See under "Reply Codes" in the AMQP specification)

closeMessage - a message indicating the reason for closing the connection

Throws:

IOException - if an I/O problem is encountered

See Also:

• Connection.close(int, String)

addShutdownListener

public void addShutdownListener(ShutdownListener listener)

Description copied from interface: ShutdownNotifier

Add shutdown listener. If the component is already closed, handler is fired immediately

Specified by:

addShutdownListener in interface ShutdownNotifier

Parameters:

listener - ShutdownListener to the component

See Also:

• ShutdownNotifier.addShutdownListener(com.rabbitmq.client.ShutdownListener)

removeShutdownListener

public void removeShutdownListener(ShutdownListener listener)

Description copied from interface: ShutdownNotifier

Remove shutdown listener for the component.

Specified by:

removeShutdownListener in interface ShutdownNotifier

Parameters:

listener - ShutdownListener to be removed

See Also:

• ShutdownNotifier.removeShutdownListener(com.rabbitmq.client.ShutdownListener)

notifyListeners

public void notifyListeners()

Description copied from interface: ShutdownNotifier

Protected API - notify the listeners attached to the component

Specified by:

notifyListeners in interface ShutdownNotifier

See Also:

• ShutdownNotifier.notifyListeners()

addRecoveryListener

public void addRecoveryListener(RecoveryListener listener)

Adds the recovery listener

Specified by:

addRecoveryListener in interface Recoverable

Parameters:

listener - RecoveryListener to execute after this connection recovers from network failure

removeRecoveryListener

public void removeRecoveryListener(RecoveryListener listener)

Removes the recovery listener

Specified by:

removeRecoveryListener in interface Recoverable

Parameters:

listener - RecoveryListener to remove

getExceptionHandler

public ExceptionHandler getExceptionHandler()

Description copied from interface: Connection

Get the exception handler.

Specified by:

getExceptionHandler in interface Connection

See Also:

• AMQConnection.getExceptionHandler()

getPort

public int getPort()

Description copied from interface: Connection

Retrieve the port number.

Specified by:

getPort in interface Connection

Specified by:

getPort in interface NetworkConnection

Returns:

the port number of the peer we're connected to.

See Also:

• Connection.getPort()

getAddress

public InetAddress getAddress()

Description copied from interface: Connection

Retrieve the host.

Specified by:

getAddress in interface Connection

Specified by:

getAddress in interface NetworkConnection

Returns:

the hostname of the peer we're connected to.

See Also:

• Connection.getAddress()

getLocalAddress

public InetAddress getLocalAddress()

Description copied from interface: NetworkConnection

Retrieve the local host.

Specified by:

getLocalAddress in interface NetworkConnection

Returns:

client socket address

getLocalPort

public int getLocalPort()

Description copied from interface: NetworkConnection

Retrieve the local port number.

Specified by:

getLocalPort in interface NetworkConnection

Returns:

client socket port

addAutomaticRecoveryListener

private void addAutomaticRecoveryListener(RecoveryAwareAMQConnection newConn)

shouldTriggerConnectionRecovery

protected boolean shouldTriggerConnectionRecovery(ShutdownSignalException cause)

addQueueRecoveryListener

public void addQueueRecoveryListener(QueueRecoveryListener listener)

Not part of the public API. Mean to be used by JVM RabbitMQ clients that build on top of the Java client and need to be notified when server-named queue name changes after recovery.

Parameters:

listener - listener that observes queue name changes after recovery

removeQueueRecoveryListener

public void removeQueueRecoveryListener(QueueRecoveryListener listener)

Parameters:

listener - listener to be removed

See Also:

• addQueueRecoveryListener(QueueRecoveryListener)

addConsumerRecoveryListener

public void addConsumerRecoveryListener(ConsumerRecoveryListener listener)

Not part of the public API. Mean to be used by JVM RabbitMQ clients that build on top of the Java client and need to be notified when consumer tag changes after recovery.

Parameters:

listener - listener that observes consumer tag changes after recovery

removeConsumerRecoveryListener

public void removeConsumerRecoveryListener(ConsumerRecoveryListener listener)

Parameters:

listener - listener to be removed

See Also:

• addConsumerRecoveryListener(ConsumerRecoveryListener)

getRecoveredQueueNameSupplier

RecoveredQueueNameSupplier getRecoveredQueueNameSupplier()

beginAutomaticRecovery

private void beginAutomaticRecovery()
                             throws InterruptedException

Throws:

InterruptedException

recoverShutdownListeners

private void recoverShutdownListeners(RecoveryAwareAMQConnection newConn)

recoverBlockedListeners

private void recoverBlockedListeners(RecoveryAwareAMQConnection newConn)

recoverConnection

private RecoveryAwareAMQConnection recoverConnection()
                                              throws InterruptedException

Throws:

InterruptedException

recoverChannels

private void recoverChannels(RecoveryAwareAMQConnection newConn)

recoverChannel

public void recoverChannel(AutorecoveringChannel channel)
                    throws IOException

Throws:

IOException

notifyRecoveryListenersComplete

private void notifyRecoveryListenersComplete()

notifyRecoveryListenersStarted

private void notifyRecoveryListenersStarted()

notifyTopologyRecoveryListenersStarted

private void notifyTopologyRecoveryListenersStarted()

recoverChannelAndTopology

public void recoverChannelAndTopology(AutorecoveringChannel channel)

Recover a closed channel and all topology (i.e. RecordedEntities) associated to it. Any errors will be sent to the getExceptionHandler().

Parameters:

channel - channel to recover

Throws:

IllegalArgumentException - if this channel is not owned by this connection

recoverTopology

private void recoverTopology(ExecutorService executor)

recoverExchange

public void recoverExchange(RecordedExchange x,
 boolean retry)

recoverQueue

public void recoverQueue(String oldName,
 RecordedQueue q,
 boolean retry)

Recover the queue. Any exceptions during recovery will be delivered to the connection's ExceptionHandler.

Parameters:

oldName - queue name

q - recorded queue

retry - whether to retry the recovery if an error occurs and a RetryHandler was configured on the connection

recoverQueue

void recoverQueue(String oldName,
 RecordedQueue q)
           throws Exception

Recover the queue. Errors are not retried and not delivered to the connection's ExceptionHandler

Parameters:

oldName - queue name

q - recorded queue

Throws:

Exception - if an error occurs recovering the queue

internalRecoverQueue

private void internalRecoverQueue(String oldName,
 RecordedQueue q,
 boolean retry)
                           throws Exception

Throws:

Exception

recoverBinding

public void recoverBinding(RecordedBinding b,
 boolean retry)

recoverConsumer

public void recoverConsumer(String tag,
 RecordedConsumer consumer,
 boolean retry)

Recover the consumer. Any exceptions during recovery will be delivered to the connection's ExceptionHandler.

Parameters:

tag - consumer tag

consumer - recorded consumer

retry - whether to retry the recovery if an error occurs and a RetryHandler was configured on the connection

recoverConsumer

void recoverConsumer(String tag,
 RecordedConsumer consumer)
              throws Exception

Recover the consumer. Errors are not retried and not delivered to the connection's ExceptionHandler

Parameters:

tag - consumer tag

consumer - recorded consumer

Throws:

Exception - if an error occurs recovering the consumer

internalRecoverConsumer

private void internalRecoverConsumer(String tag,
 RecordedConsumer consumer,
 boolean retry)
                              throws Exception

Throws:

Exception

wrapRetryIfNecessary

private <T> RetryResult wrapRetryIfNecessary(RecordedEntity entity,
 Callable<T> recoveryAction)
                                      throws Exception

Throws:

Exception

propagateQueueNameChangeToBindings

private void propagateQueueNameChangeToBindings(String oldName,
 String newName)

propagateQueueNameChangeToConsumers

private void propagateQueueNameChangeToConsumers(String oldName,
 String newName)

recoverEntitiesAsynchronously

private void recoverEntitiesAsynchronously(ExecutorService executor,
 Collection<? extends RecordedEntity> recordedEntities)
                                    throws InterruptedException

Throws:

InterruptedException

groupEntitiesByChannel

private <E extends RecordedEntity>
List<Callable<Object>> groupEntitiesByChannel(Collection<E> entities)

recordQueueBinding

void recordQueueBinding(AutorecoveringChannel ch,
 String queue,
 String exchange,
 String routingKey,
 Map<String,Object> arguments)

deleteRecordedQueueBinding

boolean deleteRecordedQueueBinding(AutorecoveringChannel ch,
 String queue,
 String exchange,
 String routingKey,
 Map<String,Object> arguments)

recordExchangeBinding

void recordExchangeBinding(AutorecoveringChannel ch,
 String destination,
 String source,
 String routingKey,
 Map<String,Object> arguments)

deleteRecordedExchangeBinding

boolean deleteRecordedExchangeBinding(AutorecoveringChannel ch,
 String destination,
 String source,
 String routingKey,
 Map<String,Object> arguments)

recordQueue

void recordQueue(AMQP.Queue.DeclareOk ok,
 RecordedQueue q)

recordQueue

void recordQueue(String queue,
 RecordedQueue meta)

deleteRecordedQueue

void deleteRecordedQueue(String queue)

excludeQueueFromRecovery

public void excludeQueueFromRecovery(String queue,
 boolean ifUnused)

Exclude the queue from the list of queues to recover after connection failure. Intended to be used in usecases where you want to remove the queue from this connection's recovery list but don't want to delete the queue from the server.

Parameters:

queue - queue name to exclude from recorded recovery queues

ifUnused - if true, the RecordedQueue will only be excluded if no local consumers are using it.

recordExchange

void recordExchange(String exchange,
 RecordedExchange x)

deleteRecordedExchange

void deleteRecordedExchange(String exchange)

recordConsumer

void recordConsumer(String result,
 RecordedConsumer consumer)

deleteRecordedConsumer

RecordedConsumer deleteRecordedConsumer(String consumerTag)

maybeDeleteRecordedAutoDeleteQueue

void maybeDeleteRecordedAutoDeleteQueue(String queue)

maybeDeleteRecordedAutoDeleteExchange

void maybeDeleteRecordedAutoDeleteExchange(String exchange)

hasMoreDestinationsBoundToExchange

boolean hasMoreDestinationsBoundToExchange(List<RecordedBinding> bindings,
 String exchange)

hasMoreConsumersOnQueue

boolean hasMoreConsumersOnQueue(Collection<RecordedConsumer> consumers,
 String queue)

removeBindingsWithDestination

Set<RecordedBinding> removeBindingsWithDestination(String s)

getRecordedQueues

public Map<String, RecordedQueue> getRecordedQueues()

getRecordedExchanges

public Map<String, RecordedExchange> getRecordedExchanges()

getRecordedBindings

public List<RecordedBinding> getRecordedBindings()

getRecordedConsumers

public Map<String, RecordedConsumer> getRecordedConsumers()

toString

public String toString()

Overrides:

toString in class Object

getId

public String getId()

Public API - Returns a unique ID for this connection. This ID must be unique, otherwise some services like the metrics collector won't work properly. This ID doesn't have to be provided by the client, services that require it will be assigned automatically if not set.

Specified by:

getId in interface Connection

Returns:

unique ID for this connection.

setId

public void setId(String id)

Public API - Sets a unique ID for this connection. This ID must be unique, otherwise some services like the metrics collector won't work properly. This ID doesn't have to be provided by the client, services that require it will be assigned automatically if not set.

Specified by:

setId in interface Connection