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, observationCollector

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, ObservationCollector observationCollector)

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 Details

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,
 ObservationCollector observationCollector)

Method Details

instantiateChannel

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

Overrides:

instantiateChannel in class ChannelManager