Package com.rabbitmq.client.impl.recovery

Class RecoveryAwareChannelManager

java.lang.Object

com.rabbitmq.client.impl.ChannelManager

com.rabbitmq.client.impl.recovery.RecoveryAwareChannelManager

public class RecoveryAwareChannelManager
extends ChannelManager

Since:

3.3.0

Field Summary

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

metricsCollector

Constructor Summary

Constructors

Constructor	Description
RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax)
RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory)
RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory, MetricsCollector metricsCollector)

Method Summary

Modifier and Type	Method	Description
protected ChannelN	instantiateChannel(AMQConnection connection, int channelNumber, ConsumerWorkService workService)

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

createChannel, createChannel, getChannel, getChannelMax, getShutdownExecutor, handleSignal, releaseChannelNumber, setChannelShutdownTimeout, setShutdownExecutor

Methods inherited from class java.lang.Object

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

Constructor Detail

RecoveryAwareChannelManager

public RecoveryAwareChannelManager(ConsumerWorkService workService,
                                   int channelMax)

RecoveryAwareChannelManager

public RecoveryAwareChannelManager(ConsumerWorkService workService,
                                   int channelMax,
                                   ThreadFactory threadFactory)

RecoveryAwareChannelManager

public RecoveryAwareChannelManager(ConsumerWorkService workService,
                                   int channelMax,
                                   ThreadFactory threadFactory,
                                   MetricsCollector metricsCollector)

Method Detail

instantiateChannel

protected ChannelN instantiateChannel(AMQConnection connection,
                                      int channelNumber,
                                      ConsumerWorkService workService)

Overrides:

instantiateChannel in class ChannelManager