Package com.rabbitmq.client.impl

Class ChannelManager

java.lang.Object

com.rabbitmq.client.impl.ChannelManager

Direct Known Subclasses:

RecoveryAwareChannelManager

public class ChannelManager
extends Object

Manages a set of channels, indexed by channel number (1.._channelMax).

Field Summary

Fields

Modifier and Type	Field	Description
protected final MetricsCollector	metricsCollector
protected final ObservationCollector	observationCollector

Constructor Summary

Constructors

Constructor	Description
ChannelManager(ConsumerWorkService workService, int channelMax)
ChannelManager(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory)
ChannelManager(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory, MetricsCollector metricsCollector, ObservationCollector observationCollector)

Method Summary

Modifier and Type	Method	Description
ChannelN	createChannel(AMQConnection connection)
ChannelN	createChannel(AMQConnection connection, int channelNumber)
ChannelN	getChannel(int channelNumber)	Looks up a channel on this connection.
int	getChannelMax()
ExecutorService	getShutdownExecutor()
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.
void	setChannelShutdownTimeout(int channelShutdownTimeout)	Set the shutdown timeout for channels.
void	setShutdownExecutor(ExecutorService shutdownExecutor)

Methods inherited from class java.lang.Object

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

Field Details

metricsCollector

protected final MetricsCollector metricsCollector

observationCollector

protected final ObservationCollector observationCollector

Constructor Details

ChannelManager

public ChannelManager(ConsumerWorkService workService,
 int channelMax)

ChannelManager

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

ChannelManager

public ChannelManager(ConsumerWorkService workService,
 int channelMax,
 ThreadFactory threadFactory,
 MetricsCollector metricsCollector,
 ObservationCollector observationCollector)

Method Details

getChannelMax

public int getChannelMax()

getChannel

public ChannelN getChannel(int channelNumber)

Looks up a channel on this connection.

Parameters:

channelNumber - the number of the required channel

Returns:

the channel on this connection with number channelNumber

Throws:

com.rabbitmq.client.impl.UnknownChannelException - if there is no channel with number channelNumber on this connection

handleSignal

public void handleSignal(ShutdownSignalException signal)

Handle shutdown. All the managed Channels are shutdown.

Parameters:

signal - reason for shutdown

createChannel

public ChannelN createChannel(AMQConnection connection)
                       throws IOException

Throws:

IOException

createChannel

public ChannelN createChannel(AMQConnection connection,
 int channelNumber)
                       throws IOException

Throws:

IOException

instantiateChannel

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

releaseChannelNumber

public void releaseChannelNumber(ChannelN channel)

Remove the channel from the channel map and free the number for re-use. This method must be safe to call multiple times on the same channel. If it is not then things go badly wrong.

getShutdownExecutor

public ExecutorService getShutdownExecutor()

setShutdownExecutor

public void setShutdownExecutor(ExecutorService shutdownExecutor)

setChannelShutdownTimeout

public void setChannelShutdownTimeout(int channelShutdownTimeout)

Set the shutdown timeout for channels. This is the amount of time the manager waits for a channel to shutdown before giving up. Works only when the shutdownExecutor property is set. Default to ConnectionFactory.DEFAULT_HEARTBEAT + 5 % seconds

Parameters:

channelShutdownTimeout - shutdown timeout in milliseconds