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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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, 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 Detail

RecoveryAwareAMQConnection

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

RecoveryAwareAMQConnection

public RecoveryAwareAMQConnection(ConnectionParams params,
                                  FrameHandler handler)

Method Detail

instantiateChannelManager

protected RecoveryAwareChannelManager instantiateChannelManager(int channelMax,
                                                                ThreadFactory threadFactory)

Overrides:

instantiateChannelManager in class AMQConnection