Package com.rabbitmq.client.impl.recovery

Class RecoveryAwareAMQConnection

java.lang.Object

com.rabbitmq.client.impl.ShutdownNotifierComponent

com.rabbitmq.client.impl.AMQConnection

com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnection

All Implemented Interfaces:

Connection, NetworkConnection, ShutdownNotifier, Closeable, AutoCloseable

public class RecoveryAwareAMQConnection
extends AMQConnection

AMQConnection modification that uses RecoveryAwareChannelN

Since:

3.3.0

Field Summary

Fields inherited from class com.rabbitmq.client.impl.AMQConnection

_workService, CHANNEL_SHUTDOWN_TIMEOUT_MULTIPLIER, metricsCollector, observationCollector

Constructor Summary

Constructors

Constructor	Description
RecoveryAwareAMQConnection(ConnectionParams params, FrameHandler handler)
RecoveryAwareAMQConnection(ConnectionParams params, FrameHandler handler, MetricsCollector metricsCollector, ObservationCollector observationCollector)

Method Summary

Modifier and Type	Method	Description
protected RecoveryAwareChannelManager	instantiateChannelManager(int channelMax, ThreadFactory threadFactory)

Methods inherited from class com.rabbitmq.client.impl.AMQConnection

abort, abort, abort, abort, addBlockedListener, addBlockedListener, addRecoveryCanBeginListener, clearBlockedListeners, close, close, close, close, close, close, configureChannelManager, createChannel, createChannel, defaultClientProperties, disconnectChannel, doFinalShutdown, flush, getAddress, getChannelMax, getChannelRpcTimeout, getClientProperties, getClientProvidedName, getExceptionHandler, getFrameHandler, getFrameMax, getHeartbeat, getId, getLocalAddress, getLocalPort, getPort, getServerProperties, getThreadFactory, getTrafficListener, handleConnectionClose, handleHeartbeatFailure, handleIoError, handleReadFrame, hasBrokerInitiatedShutdown, ioLoopThread, isRunning, negotiateChannelMax, processControlCommand, removeBlockedListener, removeRecoveryCanBeginListener, setHeartbeat, setId, setThreadFactory, shutdown, start, startMainLoop, toString, willCheckRpcResponseType, willShutDownConsumerExecutor, writeFrame

Methods inherited from class com.rabbitmq.client.impl.ShutdownNotifierComponent

addShutdownListener, getCloseReason, isOpen, notifyListeners, removeShutdownListener, setShutdownCauseIfOpen

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.rabbitmq.client.Connection

openChannel, openChannel

Methods inherited from interface com.rabbitmq.client.ShutdownNotifier

addShutdownListener, getCloseReason, isOpen, notifyListeners, removeShutdownListener

Constructor Details

RecoveryAwareAMQConnection

public RecoveryAwareAMQConnection(ConnectionParams params,
 FrameHandler handler,
 MetricsCollector metricsCollector,
 ObservationCollector observationCollector)

RecoveryAwareAMQConnection

public RecoveryAwareAMQConnection(ConnectionParams params,
 FrameHandler handler)

Method Details

instantiateChannelManager

protected RecoveryAwareChannelManager instantiateChannelManager(int channelMax,
 ThreadFactory threadFactory)

Overrides:

instantiateChannelManager in class AMQConnection