public class RecoveryAwareChannelManager extends ChannelManager
Constructor and Description |
---|
RecoveryAwareChannelManager(ConsumerWorkService workService,
int channelMax) |
RecoveryAwareChannelManager(ConsumerWorkService workService,
int channelMax,
java.util.concurrent.ThreadFactory threadFactory) |
Modifier and Type | Method and Description |
---|---|
protected ChannelN |
instantiateChannel(AMQConnection connection,
int channelNumber,
ConsumerWorkService workService) |
createChannel, createChannel, getChannel, getChannelMax, getShutdownExecutor, handleSignal, releaseChannelNumber, setShutdownExecutor
public RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax)
public RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax, java.util.concurrent.ThreadFactory threadFactory)
protected ChannelN instantiateChannel(AMQConnection connection, int channelNumber, ConsumerWorkService workService)
instantiateChannel
in class ChannelManager