public class ChannelManager
extends java.lang.Object
1.._channelMax
).Constructor and Description |
---|
ChannelManager(ConsumerWorkService workService,
int channelMax) |
ChannelManager(ConsumerWorkService workService,
int channelMax,
java.util.concurrent.ThreadFactory threadFactory) |
Modifier and Type | Method and Description |
---|---|
ChannelN |
createChannel(AMQConnection connection) |
ChannelN |
createChannel(AMQConnection connection,
int channelNumber) |
ChannelN |
getChannel(int channelNumber)
Looks up a channel on this connection.
|
int |
getChannelMax() |
void |
handleSignal(ShutdownSignalException signal)
Handle shutdown.
|
protected ChannelN |
instantiateChannel(AMQConnection connection,
int channelNumber,
ConsumerWorkService workService) |
void |
releaseChannelNumber(ChannelN channel)
Remove the channel from the channel map and free the number for re-use.
|
public ChannelManager(ConsumerWorkService workService, int channelMax)
public ChannelManager(ConsumerWorkService workService, int channelMax, java.util.concurrent.ThreadFactory threadFactory)
public int getChannelMax()
public ChannelN getChannel(int channelNumber)
channelNumber
- the number of the required channelchannelNumber
UnknownChannelException
- if there is no channel with number channelNumber
on this connectionpublic void handleSignal(ShutdownSignalException signal)
Channel
s are shutdown.signal
- reason for shutdownpublic ChannelN createChannel(AMQConnection connection) throws java.io.IOException
java.io.IOException
public ChannelN createChannel(AMQConnection connection, int channelNumber) throws java.io.IOException
java.io.IOException
protected ChannelN instantiateChannel(AMQConnection connection, int channelNumber, ConsumerWorkService workService)
public void releaseChannelNumber(ChannelN channel)