public class RecoveryAwareAMQConnection extends AMQConnection
AMQConnection
modification that uses RecoveryAwareChannelN
_workService
Constructor and Description |
---|
RecoveryAwareAMQConnection(ConnectionParams params,
FrameHandler handler) |
Modifier and Type | Method and Description |
---|---|
protected RecoveryAwareChannelManager |
instantiateChannelManager(int channelMax,
java.util.concurrent.ThreadFactory threadFactory) |
abort, abort, abort, abort, addBlockedListener, clearBlockedListeners, close, close, close, close, close, close, createChannel, createChannel, defaultClientProperties, disconnectChannel, flush, getAddress, getChannelMax, getClientProperties, getClientProvidedName, getExceptionHandler, getFrameHandler, getFrameMax, getHeartbeat, getLocalAddress, getLocalPort, getPort, getServerProperties, getThreadFactory, handleConnectionClose, negotiateChannelMax, processControlCommand, removeBlockedListener, setHeartbeat, setThreadFactory, shutdown, start, toString, willShutDownConsumerExecutor, writeFrame
addShutdownListener, getCloseReason, isOpen, notifyListeners, removeShutdownListener, setShutdownCauseIfOpen
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addShutdownListener, getCloseReason, isOpen, notifyListeners, removeShutdownListener
public RecoveryAwareAMQConnection(ConnectionParams params, FrameHandler handler)
protected RecoveryAwareChannelManager instantiateChannelManager(int channelMax, java.util.concurrent.ThreadFactory threadFactory)
instantiateChannelManager
in class AMQConnection