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, java.util.concurrent.ThreadFactory threadFactory)
RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax, java.util.concurrent.ThreadFactory threadFactory, MetricsCollector metricsCollector, ObservationCollector observationCollector)
-
Method Summary
All Methods Instance Methods Concrete Methods 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
-
-
-
-
Constructor Detail
-
RecoveryAwareChannelManager
public RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax)
-
RecoveryAwareChannelManager
public RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax, java.util.concurrent.ThreadFactory threadFactory)
-
RecoveryAwareChannelManager
public RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax, java.util.concurrent.ThreadFactory threadFactory, MetricsCollector metricsCollector, ObservationCollector observationCollector)
-
-
Method Detail
-
instantiateChannel
protected ChannelN instantiateChannel(AMQConnection connection, int channelNumber, ConsumerWorkService workService)
- Overrides:
instantiateChannel
in classChannelManager
-
-