Uses of Interface
com.rabbitmq.client.Channel

Packages that use Channel

Package	Description
com.rabbitmq.client	The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors.
com.rabbitmq.client.impl	Implementations of interfaces specified in the client API, and their supporting classes.
com.rabbitmq.client.impl.recovery	Implementation of connection and topology recovery.
com.rabbitmq.tools.jsonrpc	JSON-RPC client and server classes for supporting JSON-RPC over an AMQP transport.

Uses of Channel in com.rabbitmq.client

Subinterfaces of Channel in com.rabbitmq.client

Modifier and Type	Interface and Description
interface	RecoverableChannel Convenient interface when working against auto-recovery channels.

Methods in com.rabbitmq.client that return Channel

Modifier and Type	Method and Description
Channel	Connection.createChannel() Create a new channel, using an internally allocated channel number.
Channel	Connection.createChannel(int channelNumber) Create a new channel, using the specified channel number if possible.
Channel	RpcClient.getChannel() Retrieve the channel.
Channel	RpcServer.getChannel() Retrieve the channel.
Channel	RpcClientParams.getChannel() Set the channel to use for communication.
Channel	DefaultConsumer.getChannel() Retrieve the channel.

Methods in com.rabbitmq.client that return types with arguments of type Channel

Modifier and Type	Method and Description
default Optional<Channel>	Connection.openChannel() Create a new channel wrapped in an Optional.
default Optional<Channel>	Connection.openChannel(int channelNumber) Create a new channel, using the specified channel number if possible.

Methods in com.rabbitmq.client with parameters of type Channel

Modifier and Type	Method and Description
void	NoOpMetricsCollector.basicAck(Channel channel, long deliveryTag, boolean multiple)
void	MetricsCollector.basicAck(Channel channel, long deliveryTag, boolean multiple)
void	NoOpMetricsCollector.basicCancel(Channel channel, String consumerTag)
void	MetricsCollector.basicCancel(Channel channel, String consumerTag)
void	NoOpMetricsCollector.basicConsume(Channel channel, String consumerTag, boolean autoAck)
void	MetricsCollector.basicConsume(Channel channel, String consumerTag, boolean autoAck)
void	NoOpMetricsCollector.basicNack(Channel channel, long deliveryTag)
void	MetricsCollector.basicNack(Channel channel, long deliveryTag)
void	NoOpMetricsCollector.basicPublish(Channel channel)
void	MetricsCollector.basicPublish(Channel channel)
void	NoOpMetricsCollector.basicPublishAck(Channel channel, long deliveryTag, boolean multiple)
default void	MetricsCollector.basicPublishAck(Channel channel, long deliveryTag, boolean multiple)
void	NoOpMetricsCollector.basicPublishFailure(Channel channel, Throwable cause)
default void	MetricsCollector.basicPublishFailure(Channel channel, Throwable cause)
void	NoOpMetricsCollector.basicPublishNack(Channel channel, long deliveryTag, boolean multiple)
default void	MetricsCollector.basicPublishNack(Channel channel, long deliveryTag, boolean multiple)
void	NoOpMetricsCollector.basicPublishUnrouted(Channel channel)
default void	MetricsCollector.basicPublishUnrouted(Channel channel)
void	NoOpMetricsCollector.basicReject(Channel channel, long deliveryTag)
void	MetricsCollector.basicReject(Channel channel, long deliveryTag)
RpcClientParams	RpcClientParams.channel(Channel channel)
void	NoOpMetricsCollector.closeChannel(Channel channel)
void	MetricsCollector.closeChannel(Channel channel)
void	NoOpMetricsCollector.consumedMessage(Channel channel, long deliveryTag, boolean autoAck)
void	MetricsCollector.consumedMessage(Channel channel, long deliveryTag, boolean autoAck)
void	NoOpMetricsCollector.consumedMessage(Channel channel, long deliveryTag, String consumerTag)
void	MetricsCollector.consumedMessage(Channel channel, long deliveryTag, String consumerTag)
void	ExceptionHandler.handleChannelRecoveryException(Channel ch, Throwable exception) Perform any required exception processing for the situation when the driver thread for the connection has an exception during channel recovery that it can't otherwise deal with.
void	ExceptionHandler.handleConfirmListenerException(Channel channel, Throwable exception) Perform any required exception processing for the situation when the driver thread for the connection has called a ConfirmListener's handleAck or handleNack method, and that method has thrown an exception.
void	ExceptionHandler.handleConsumerException(Channel channel, Throwable exception, Consumer consumer, String consumerTag, String methodName) Perform any required exception processing for the situation when the driver thread for the connection has called a method on a Consumer, and that method has thrown an exception.
void	ExceptionHandler.handleReturnListenerException(Channel channel, Throwable exception) Perform any required exception processing for the situation when the driver thread for the connection has called a ReturnListener's handleReturn method, and that method has thrown an exception.
void	ExceptionHandler.handleTopologyRecoveryException(Connection conn, Channel ch, TopologyRecoveryException exception) Perform any required exception processing for the situation when the driver thread for the connection has an exception during topology (exchanges, queues, bindings, consumers) recovery that it can't otherwise deal with.
void	NoOpMetricsCollector.newChannel(Channel channel)
void	MetricsCollector.newChannel(Channel channel)

Constructors in com.rabbitmq.client with parameters of type Channel

Constructor and Description
DefaultConsumer(Channel channel) Constructs a new instance and records its association to the passed-in channel.
MapRpcServer(Channel channel)
MapRpcServer(Channel channel, String queueName)
RpcClient(Channel channel, String exchange, String routingKey) Deprecated. use RpcClient(RpcClientParams) instead, will be removed in 6.0.0
RpcClient(Channel channel, String exchange, String routingKey, int timeout) Deprecated. use RpcClient(RpcClientParams) instead, will be removed in 6.0.0
RpcClient(Channel channel, String exchange, String routingKey, String replyTo) Deprecated. use RpcClient(RpcClientParams) instead, will be removed in 6.0.0
RpcClient(Channel channel, String exchange, String routingKey, String replyTo, int timeout) Deprecated. use RpcClient(RpcClientParams) instead, will be removed in 6.0.0
RpcServer(Channel channel) Creates an RpcServer listening on a temporary exclusive autodelete queue.
RpcServer(Channel channel, String queueName) If the passed-in queue name is null, creates a server-named temporary exclusive autodelete queue to use; otherwise expects the queue to have already been declared.
StringRpcServer(Channel channel)
StringRpcServer(Channel channel, String queueName)

Uses of Channel in com.rabbitmq.client.impl

Classes in com.rabbitmq.client.impl that implement Channel

Modifier and Type	Class and Description
class	ChannelN Main interface to AMQP protocol functionality.

Methods in com.rabbitmq.client.impl that return Channel

Modifier and Type	Method and Description
Channel	AMQConnection.createChannel() Public API - Create a new channel, using an internally allocated channel number.
Channel	AMQConnection.createChannel(int channelNumber) Public API - Create a new channel, using the specified channel number if possible.

Methods in com.rabbitmq.client.impl with parameters of type Channel

Modifier and Type	Method and Description
void	ConsumerWorkService.addWork(Channel channel, Runnable runnable)
void	AbstractMetricsCollector.basicAck(Channel channel, long deliveryTag, boolean multiple)
void	AbstractMetricsCollector.basicCancel(Channel channel, String consumerTag)
void	AbstractMetricsCollector.basicConsume(Channel channel, String consumerTag, boolean autoAck)
void	AbstractMetricsCollector.basicNack(Channel channel, long deliveryTag)
void	AbstractMetricsCollector.basicPublish(Channel channel)
void	AbstractMetricsCollector.basicPublishAck(Channel channel, long deliveryTag, boolean multiple)
void	AbstractMetricsCollector.basicPublishFailure(Channel channel, Throwable cause)
void	AbstractMetricsCollector.basicPublishNack(Channel channel, long deliveryTag, boolean multiple)
void	AbstractMetricsCollector.basicPublishUnrouted(Channel channel)
void	AbstractMetricsCollector.basicReject(Channel channel, long deliveryTag)
void	AbstractMetricsCollector.closeChannel(Channel channel)
void	AbstractMetricsCollector.consumedMessage(Channel channel, long deliveryTag, boolean autoAck)
void	AbstractMetricsCollector.consumedMessage(Channel channel, long deliveryTag, String consumerTag)
protected abstract void	AbstractMetricsCollector.decrementChannelCount(Channel channel) Decrements channel count.
protected void	MicrometerMetricsCollector.decrementChannelCount(Channel channel)
protected void	StandardMetricsCollector.decrementChannelCount(Channel channel)
protected void	OpenTelemetryMetricsCollector.decrementChannelCount(Channel channel)
protected void	StrictExceptionHandler.handleChannelKiller(Channel channel, Throwable exception, String what)
protected void	ForgivingExceptionHandler.handleChannelKiller(Channel channel, Throwable exception, String what)
protected void	StrictExceptionHandler.handleChannelKiller(Channel channel, Throwable exception, String logMessage, String closeMessage)
void	ForgivingExceptionHandler.handleChannelRecoveryException(Channel ch, Throwable exception)
void	StrictExceptionHandler.handleConfirmListenerException(Channel channel, Throwable exception)
void	ForgivingExceptionHandler.handleConfirmListenerException(Channel channel, Throwable exception)
void	StrictExceptionHandler.handleConsumerException(Channel channel, Throwable exception, Consumer consumer, String consumerTag, String methodName)
void	ForgivingExceptionHandler.handleConsumerException(Channel channel, Throwable exception, Consumer consumer, String consumerTag, String methodName)
void	StrictExceptionHandler.handleReturnListenerException(Channel channel, Throwable exception)
void	ForgivingExceptionHandler.handleReturnListenerException(Channel channel, Throwable exception)
void	ForgivingExceptionHandler.handleTopologyRecoveryException(Connection conn, Channel ch, TopologyRecoveryException exception)
protected abstract void	AbstractMetricsCollector.incrementChannelCount(Channel channel) Increments channel count.
protected void	MicrometerMetricsCollector.incrementChannelCount(Channel channel)
protected void	StandardMetricsCollector.incrementChannelCount(Channel channel)
protected void	OpenTelemetryMetricsCollector.incrementChannelCount(Channel channel)
void	AbstractMetricsCollector.newChannel(Channel channel)
void	ConsumerWorkService.registerKey(Channel channel)
void	ConsumerWorkService.setUnlimited(Channel channel, boolean unlimited)
void	ConsumerWorkService.stopWork(Channel channel) Stop executing all consumer work for a particular channel

Uses of Channel in com.rabbitmq.client.impl.recovery

Classes in com.rabbitmq.client.impl.recovery that implement Channel

Modifier and Type	Class and Description
class	AutorecoveringChannel Channel implementation that is automatically recovered during connection recovery.
class	RecoveryAwareChannelN ChannelN modification that keeps track of delivery tags and avoids sending

Methods in com.rabbitmq.client.impl.recovery that return Channel

Modifier and Type	Method and Description
Channel	AutorecoveringConnection.createChannel()
Channel	AutorecoveringConnection.createChannel(int channelNumber)
Channel	AutorecoveringChannel.getDelegate()
Channel	RecordedEntity.getDelegateChannel()

Uses of Channel in com.rabbitmq.tools.jsonrpc

Constructors in com.rabbitmq.tools.jsonrpc with parameters of type Channel

Constructor and Description
JsonRpcClient(Channel channel, String exchange, String routingKey)
JsonRpcClient(Channel channel, String exchange, String routingKey, int timeout) Construct a new JsonRpcClient, passing the parameters through to RpcClient's constructor.
JsonRpcClient(Channel channel, String exchange, String routingKey, int timeout, JsonRpcMapper mapper) Construct a new JsonRpcClient, passing the parameters through to RpcClient's constructor.
JsonRpcServer(Channel channel, Class<?> interfaceClass, Object interfaceInstance) Construct a server that talks to the outside world using the given channel, and constructs a fresh temporary queue.
JsonRpcServer(Channel channel, Class<?> interfaceClass, Object interfaceInstance, JsonRpcMapper mapper)
JsonRpcServer(Channel channel, String queueName, Class<?> interfaceClass, Object interfaceInstance) Construct a server that talks to the outside world using the given channel and queue name.
JsonRpcServer(Channel channel, String queueName, Class<?> interfaceClass, Object interfaceInstance, JsonRpcMapper mapper)