org.springframework.amqp.rabbit.connection

Interface ChannelProxy

All Superinterfaces:

AutoCloseable, com.rabbitmq.client.Channel, RawTargetAccess, com.rabbitmq.client.ShutdownNotifier

public interface ChannelProxy
extends com.rabbitmq.client.Channel, RawTargetAccess

Subinterface of Channel to be implemented by Channel proxies. Allows access to the underlying target Channel

Author:

Mark Pollack, Gary Russell, Leonardo Ferreira

See Also:

CachingConnectionFactory

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.client.Channel	getTargetChannel() Return the target Channel of this proxy.
default boolean	isConfirmSelected() Return true if confirms are selected on this channel.
boolean	isTransactional() Return whether this channel has transactions enabled txSelect().

Methods inherited from interface com.rabbitmq.client.Channel

abort, abort, addConfirmListener, addConfirmListener, addReturnListener, addReturnListener, asyncCompletableRpc, asyncRpc, basicAck, basicCancel, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicGet, basicNack, basicPublish, basicPublish, basicPublish, basicQos, basicQos, basicQos, basicRecover, basicRecover, basicReject, clearConfirmListeners, clearReturnListeners, close, close, confirmSelect, consumerCount, exchangeBind, exchangeBind, exchangeBindNoWait, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclareNoWait, exchangeDeclareNoWait, exchangeDeclarePassive, exchangeDelete, exchangeDelete, exchangeDeleteNoWait, exchangeUnbind, exchangeUnbind, exchangeUnbindNoWait, getChannelNumber, getConnection, getDefaultConsumer, getNextPublishSeqNo, messageCount, queueBind, queueBind, queueBindNoWait, queueDeclare, queueDeclare, queueDeclareNoWait, queueDeclarePassive, queueDelete, queueDelete, queueDeleteNoWait, queuePurge, queueUnbind, queueUnbind, removeConfirmListener, removeReturnListener, rpc, setDefaultConsumer, txCommit, txRollback, txSelect, waitForConfirms, waitForConfirms, waitForConfirmsOrDie, waitForConfirmsOrDie

Methods inherited from interface com.rabbitmq.client.ShutdownNotifier

addShutdownListener, getCloseReason, isOpen, notifyListeners, removeShutdownListener

Method Detail

getTargetChannel

com.rabbitmq.client.Channel getTargetChannel()

Return the target Channel of this proxy.

This will typically be the native provider Channel

Returns:

the underlying Channel (never null)

isTransactional

boolean isTransactional()

Return whether this channel has transactions enabled txSelect().

Returns:

true if the channel is transactional.

Since:

1.5

isConfirmSelected

default boolean isConfirmSelected()

Return true if confirms are selected on this channel.

Returns:

true if confirms selected.

Since:

2.1