Package com.rabbitmq.client.impl.recovery

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
static final Predicate<ShutdownSignalException>	DEFAULT_CONNECTION_RECOVERY_TRIGGERING_CONDITION

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.

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.

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.

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,