Package org.springframework.amqp.rabbit.connection

Interface ChannelProxy

  • All Superinterfaces:
    java.lang.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

      All Methods Instance Methods Abstract Methods Default Methods 
      Modifier and Type Method 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.
      default boolean isPublisherConfirms()
      Return true if publisher confirms are enabled.
      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

      • isPublisherConfirms

        default boolean isPublisherConfirms()
        Return true if publisher confirms are enabled.
        Returns:
        true if publisherConfirms.