Package org.springframework.amqp.rabbit.connection

Class PublisherCallbackChannelImpl

  • All Implemented Interfaces:
    com.rabbitmq.client.Channel, com.rabbitmq.client.ConfirmListener, com.rabbitmq.client.ReturnCallback, com.rabbitmq.client.ShutdownListener, com.rabbitmq.client.ShutdownNotifier, java.lang.AutoCloseable, java.util.EventListener, PublisherCallbackChannel
    public class PublisherCallbackChannelImpl
extends java.lang.Object
implements PublisherCallbackChannel, com.rabbitmq.client.ConfirmListener, com.rabbitmq.client.ReturnCallback, com.rabbitmq.client.ShutdownListener
    Channel wrapper to allow a single listener able to handle confirms from multiple channels.
    Since:
    1.0.1
    Author:
    Gary Russell, Arnaud Cogoluègnes, Artem Bilan

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void abort()  
      void abort​(int closeCode, java.lang.String closeMessage)  
      com.rabbitmq.client.ConfirmListener addConfirmListener​(com.rabbitmq.client.ConfirmCallback ackCallback, com.rabbitmq.client.ConfirmCallback nackCallback)  
      void addConfirmListener​(com.rabbitmq.client.ConfirmListener listener)  
      void addListener​(PublisherCallbackChannel.Listener listener)
      Add the listener and return the internal map of pending confirmations for that listener.
      void addPendingConfirm​(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm)
      Adds a pending confirmation to this channel's map.
      com.rabbitmq.client.ReturnListener addReturnListener​(com.rabbitmq.client.ReturnCallback returnCallback)
      Added to the 5.0.x client.
      void addReturnListener​(com.rabbitmq.client.ReturnListener listener)  
      void addShutdownListener​(com.rabbitmq.client.ShutdownListener listener)  
      java.util.concurrent.CompletableFuture<com.rabbitmq.client.Command> asyncCompletableRpc​(com.rabbitmq.client.Method method)
      Added to the 5.0.x client.
      void asyncRpc​(com.rabbitmq.client.Method method)  
      void basicAck​(long deliveryTag, boolean multiple)  
      void basicCancel​(java.lang.String consumerTag)  
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, com.rabbitmq.client.Consumer callback)  
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, boolean noLocal, boolean exclusive, java.util.Map<java.lang.String,​java.lang.Object> arguments, com.rabbitmq.client.Consumer callback)  
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, boolean noLocal, boolean exclusive, java.util.Map<java.lang.String,​java.lang.Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, boolean noLocal, boolean exclusive, java.util.Map<java.lang.String,​java.lang.Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, boolean noLocal, boolean exclusive, java.util.Map<java.lang.String,​java.lang.Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, com.rabbitmq.client.Consumer callback)  
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.util.Map<java.lang.String,​java.lang.Object> arguments, com.rabbitmq.client.Consumer callback)
      Added to the 3.3.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.util.Map<java.lang.String,​java.lang.Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.util.Map<java.lang.String,​java.lang.Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, boolean autoAck, java.util.Map<java.lang.String,​java.lang.Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, com.rabbitmq.client.Consumer callback)  
      java.lang.String basicConsume​(java.lang.String queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
      Added to the 5.0.x client.
      java.lang.String basicConsume​(java.lang.String queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
      Added to the 5.0.x client.
      com.rabbitmq.client.GetResponse basicGet​(java.lang.String queue, boolean autoAck)  
      void basicNack​(long deliveryTag, boolean multiple, boolean requeue)  
      void basicPublish​(java.lang.String exchange, java.lang.String routingKey, boolean mandatory, boolean immediate, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body)  
      void basicPublish​(java.lang.String exchange, java.lang.String routingKey, boolean mandatory, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body)  
      void basicPublish​(java.lang.String exchange, java.lang.String routingKey, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body)  
      void basicQos​(int prefetchCount)  
      void basicQos​(int prefetchCount, boolean global)
      Added to the 3.3.x client.
      void basicQos​(int prefetchSize, int prefetchCount, boolean global)  
      com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover()  
      com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover​(boolean requeue)  
      void basicReject​(long deliveryTag, boolean requeue)  
      void clearConfirmListeners()  
      void clearReturnListeners()  
      void close()  
      void close​(int closeCode, java.lang.String closeMessage)  
      com.rabbitmq.client.AMQP.Confirm.SelectOk confirmSelect()  
      long consumerCount​(java.lang.String queue)  
      boolean equals​(java.lang.Object obj)  
      com.rabbitmq.client.AMQP.Exchange.BindOk exchangeBind​(java.lang.String destination, java.lang.String source, java.lang.String routingKey)  
      com.rabbitmq.client.AMQP.Exchange.BindOk exchangeBind​(java.lang.String destination, java.lang.String source, java.lang.String routingKey, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      void exchangeBindNoWait​(java.lang.String destination, java.lang.String source, java.lang.String routingKey, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange, com.rabbitmq.client.BuiltinExchangeType type)  
      com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable)  
      com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange, java.lang.String type)  
      com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange, java.lang.String type, boolean durable)  
      com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange, java.lang.String type, boolean durable, boolean autoDelete, boolean internal, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange, java.lang.String type, boolean durable, boolean autoDelete, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      void exchangeDeclareNoWait​(java.lang.String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      void exchangeDeclareNoWait​(java.lang.String exchange, java.lang.String type, boolean durable, boolean autoDelete, boolean internal, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclarePassive​(java.lang.String name)  
      com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete​(java.lang.String exchange)  
      com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete​(java.lang.String exchange, boolean ifUnused)  
      void exchangeDeleteNoWait​(java.lang.String exchange, boolean ifUnused)  
      com.rabbitmq.client.AMQP.Exchange.UnbindOk exchangeUnbind​(java.lang.String destination, java.lang.String source, java.lang.String routingKey)  
      com.rabbitmq.client.AMQP.Exchange.UnbindOk exchangeUnbind​(java.lang.String destination, java.lang.String source, java.lang.String routingKey, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      void exchangeUnbindNoWait​(java.lang.String destination, java.lang.String source, java.lang.String routingKey, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      java.util.Collection<PendingConfirm> expire​(PublisherCallbackChannel.Listener listener, long cutoffTime)
      Expire (remove) any PendingConfirms created before cutoffTime for the supplied listener and return them to the caller.
      static PublisherCallbackChannelFactory factory()  
      int getChannelNumber()  
      com.rabbitmq.client.ShutdownSignalException getCloseReason()  
      com.rabbitmq.client.Connection getConnection()  
      com.rabbitmq.client.Consumer getDefaultConsumer()  
      com.rabbitmq.client.Channel getDelegate()
      Use this to invoke methods on the underlying rabbit client Channel that are not supported by this implementation.
      long getNextPublishSeqNo()  
      int getPendingConfirmsCount()
      Get the total pending confirms count.
      int getPendingConfirmsCount​(PublisherCallbackChannel.Listener listener)
      Get the PendingConfirms count.
      void handle​(com.rabbitmq.client.Return returned)  
      void handleAck​(long seq, boolean multiple)  
      void handleNack​(long seq, boolean multiple)  
      int hashCode()  
      boolean isOpen()  
      long messageCount​(java.lang.String queue)  
      void notifyListeners()  
      com.rabbitmq.client.AMQP.Queue.BindOk queueBind​(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey)  
      com.rabbitmq.client.AMQP.Queue.BindOk queueBind​(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      void queueBindNoWait​(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare()  
      com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare​(java.lang.String queue, boolean durable, boolean exclusive, boolean autoDelete, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      void queueDeclareNoWait​(java.lang.String queue, boolean durable, boolean exclusive, boolean autoDelete, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclarePassive​(java.lang.String queue)  
      com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete​(java.lang.String queue)  
      com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete​(java.lang.String queue, boolean ifUnused, boolean ifEmpty)  
      void queueDeleteNoWait​(java.lang.String queue, boolean ifUnused, boolean ifEmpty)  
      com.rabbitmq.client.AMQP.Queue.PurgeOk queuePurge​(java.lang.String queue)  
      com.rabbitmq.client.AMQP.Queue.UnbindOk queueUnbind​(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey)  
      com.rabbitmq.client.AMQP.Queue.UnbindOk queueUnbind​(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey, java.util.Map<java.lang.String,​java.lang.Object> arguments)  
      boolean removeConfirmListener​(com.rabbitmq.client.ConfirmListener listener)  
      boolean removeReturnListener​(com.rabbitmq.client.ReturnListener listener)  
      void removeShutdownListener​(com.rabbitmq.client.ShutdownListener listener)  
      com.rabbitmq.client.Command rpc​(com.rabbitmq.client.Method method)  
      void setAfterAckCallback​(java.util.function.Consumer<com.rabbitmq.client.Channel> callback)
      Set a callback to be invoked after the ack/nack has been handled.
      void setDefaultConsumer​(com.rabbitmq.client.Consumer consumer)  
      void shutdownCompleted​(com.rabbitmq.client.ShutdownSignalException cause)  
      java.lang.String toString()  
      com.rabbitmq.client.AMQP.Tx.CommitOk txCommit()  
      com.rabbitmq.client.AMQP.Tx.RollbackOk txRollback()  
      com.rabbitmq.client.AMQP.Tx.SelectOk txSelect()  
      boolean waitForConfirms()  
      boolean waitForConfirms​(long timeout)  
      void waitForConfirmsOrDie()  
      void waitForConfirmsOrDie​(long timeout)  

      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    • Constructor Detail

      • PublisherCallbackChannelImpl

        public PublisherCallbackChannelImpl​(com.rabbitmq.client.Channel delegate,
                                    java.util.concurrent.ExecutorService executor)
        Create a PublisherCallbackChannelImpl instance based on the provided delegate and executor.
        Parameters:
        delegate - the delegate channel.
        executor - the executor.

    • Method Detail

      • setAfterAckCallback

        public void setAfterAckCallback​(java.util.function.Consumer<com.rabbitmq.client.Channel> callback)
        Description copied from interface: PublisherCallbackChannel
        Set a callback to be invoked after the ack/nack has been handled.
        Specified by:
        setAfterAckCallback in interface PublisherCallbackChannel
        Parameters:
        callback - the callback.

      • addShutdownListener

        public void addShutdownListener​(com.rabbitmq.client.ShutdownListener listener)
        Specified by:
        addShutdownListener in interface com.rabbitmq.client.ShutdownNotifier

      • removeShutdownListener

        public void removeShutdownListener​(com.rabbitmq.client.ShutdownListener listener)
        Specified by:
        removeShutdownListener in interface com.rabbitmq.client.ShutdownNotifier

      • getCloseReason

        public com.rabbitmq.client.ShutdownSignalException getCloseReason()
        Specified by:
        getCloseReason in interface com.rabbitmq.client.ShutdownNotifier

      • notifyListeners

        public void notifyListeners()
        Specified by:
        notifyListeners in interface com.rabbitmq.client.ShutdownNotifier

      • isOpen

        public boolean isOpen()
        Specified by:
        isOpen in interface com.rabbitmq.client.ShutdownNotifier

      • getChannelNumber

        public int getChannelNumber()
        Specified by:
        getChannelNumber in interface com.rabbitmq.client.Channel

      • getConnection

        public com.rabbitmq.client.Connection getConnection()
        Specified by:
        getConnection in interface com.rabbitmq.client.Channel

      • close

        public void close​(int closeCode,
                  java.lang.String closeMessage)
           throws java.io.IOException,
                  java.util.concurrent.TimeoutException
        Specified by:
        close in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        java.util.concurrent.TimeoutException

      • abort

        public void abort()
           throws java.io.IOException
        Specified by:
        abort in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • abort

        public void abort​(int closeCode,
                  java.lang.String closeMessage)
           throws java.io.IOException
        Specified by:
        abort in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • getDefaultConsumer

        public com.rabbitmq.client.Consumer getDefaultConsumer()
        Specified by:
        getDefaultConsumer in interface com.rabbitmq.client.Channel

      • setDefaultConsumer

        public void setDefaultConsumer​(com.rabbitmq.client.Consumer consumer)
        Specified by:
        setDefaultConsumer in interface com.rabbitmq.client.Channel

      • basicQos

        public void basicQos​(int prefetchSize,
                     int prefetchCount,
                     boolean global)
              throws java.io.IOException
        Specified by:
        basicQos in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicQos

        public void basicQos​(int prefetchCount,
                     boolean global)
              throws java.io.IOException
        Added to the 3.3.x client.
        Specified by:
        basicQos in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        1.3.3

      • basicQos

        public void basicQos​(int prefetchCount)
              throws java.io.IOException
        Specified by:
        basicQos in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicPublish

        public void basicPublish​(java.lang.String exchange,
                         java.lang.String routingKey,
                         com.rabbitmq.client.AMQP.BasicProperties props,
                         byte[] body)
                  throws java.io.IOException
        Specified by:
        basicPublish in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicPublish

        public void basicPublish​(java.lang.String exchange,
                         java.lang.String routingKey,
                         boolean mandatory,
                         boolean immediate,
                         com.rabbitmq.client.AMQP.BasicProperties props,
                         byte[] body)
                  throws java.io.IOException
        Specified by:
        basicPublish in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicPublish

        public void basicPublish​(java.lang.String exchange,
                         java.lang.String routingKey,
                         boolean mandatory,
                         com.rabbitmq.client.AMQP.BasicProperties props,
                         byte[] body)
                  throws java.io.IOException
        Specified by:
        basicPublish in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange,
                                                                   java.lang.String type)
                                                            throws java.io.IOException
        Specified by:
        exchangeDeclare in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange,
                                                                   com.rabbitmq.client.BuiltinExchangeType type)
                                                            throws java.io.IOException
        Specified by:
        exchangeDeclare in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange,
                                                                   java.lang.String type,
                                                                   boolean durable)
                                                            throws java.io.IOException
        Specified by:
        exchangeDeclare in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange,
                                                                   com.rabbitmq.client.BuiltinExchangeType type,
                                                                   boolean durable)
                                                            throws java.io.IOException
        Specified by:
        exchangeDeclare in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange,
                                                                   java.lang.String type,
                                                                   boolean durable,
                                                                   boolean autoDelete,
                                                                   java.util.Map<java.lang.String,​java.lang.Object> arguments)
                                                            throws java.io.IOException
        Specified by:
        exchangeDeclare in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange,
                                                                   com.rabbitmq.client.BuiltinExchangeType type,
                                                                   boolean durable,
                                                                   boolean autoDelete,
                                                                   java.util.Map<java.lang.String,​java.lang.Object> arguments)
                                                            throws java.io.IOException
        Specified by:
        exchangeDeclare in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange,
                                                                   java.lang.String type,
                                                                   boolean durable,
                                                                   boolean autoDelete,
                                                                   boolean internal,
                                                                   java.util.Map<java.lang.String,​java.lang.Object> arguments)
                                                            throws java.io.IOException
        Specified by:
        exchangeDeclare in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(java.lang.String exchange,
                                                                   com.rabbitmq.client.BuiltinExchangeType type,
                                                                   boolean durable,
                                                                   boolean autoDelete,
                                                                   boolean internal,
                                                                   java.util.Map<java.lang.String,​java.lang.Object> arguments)
                                                            throws java.io.IOException
        Specified by:
        exchangeDeclare in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclarePassive

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclarePassive​(java.lang.String name)
                                                                   throws java.io.IOException
        Specified by:
        exchangeDeclarePassive in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDelete

        public com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete​(java.lang.String exchange,
                                                                 boolean ifUnused)
                                                          throws java.io.IOException
        Specified by:
        exchangeDelete in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDelete

        public com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete​(java.lang.String exchange)
                                                          throws java.io.IOException
        Specified by:
        exchangeDelete in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeBind

        public com.rabbitmq.client.AMQP.Exchange.BindOk exchangeBind​(java.lang.String destination,
                                                             java.lang.String source,
                                                             java.lang.String routingKey)
                                                      throws java.io.IOException
        Specified by:
        exchangeBind in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeBind

        public com.rabbitmq.client.AMQP.Exchange.BindOk exchangeBind​(java.lang.String destination,
                                                             java.lang.String source,
                                                             java.lang.String routingKey,
                                                             java.util.Map<java.lang.String,​java.lang.Object> arguments)
                                                      throws java.io.IOException
        Specified by:
        exchangeBind in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeUnbind

        public com.rabbitmq.client.AMQP.Exchange.UnbindOk exchangeUnbind​(java.lang.String destination,
                                                                 java.lang.String source,
                                                                 java.lang.String routingKey)
                                                          throws java.io.IOException
        Specified by:
        exchangeUnbind in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeUnbind

        public com.rabbitmq.client.AMQP.Exchange.UnbindOk exchangeUnbind​(java.lang.String destination,
                                                                 java.lang.String source,
                                                                 java.lang.String routingKey,
                                                                 java.util.Map<java.lang.String,​java.lang.Object> arguments)
                                                          throws java.io.IOException
        Specified by:
        exchangeUnbind in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueDeclare

        public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare()
                                                      throws java.io.IOException
        Specified by:
        queueDeclare in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueDeclare

        public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare​(java.lang.String queue,
                                                             boolean durable,
                                                             boolean exclusive,
                                                             boolean autoDelete,
                                                             java.util.Map<java.lang.String,​java.lang.Object> arguments)
                                                      throws java.io.IOException
        Specified by:
        queueDeclare in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueDeclarePassive

        public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclarePassive​(java.lang.String queue)
                                                             throws java.io.IOException
        Specified by:
        queueDeclarePassive in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueDelete

        public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete​(java.lang.String queue)
                                                    throws java.io.IOException
        Specified by:
        queueDelete in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueDelete

        public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete​(java.lang.String queue,
                                                           boolean ifUnused,
                                                           boolean ifEmpty)
                                                    throws java.io.IOException
        Specified by:
        queueDelete in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueBind

        public com.rabbitmq.client.AMQP.Queue.BindOk queueBind​(java.lang.String queue,
                                                       java.lang.String exchange,
                                                       java.lang.String routingKey)
                                                throws java.io.IOException
        Specified by:
        queueBind in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueBind

        public com.rabbitmq.client.AMQP.Queue.BindOk queueBind​(java.lang.String queue,
                                                       java.lang.String exchange,
                                                       java.lang.String routingKey,
                                                       java.util.Map<java.lang.String,​java.lang.Object> arguments)
                                                throws java.io.IOException
        Specified by:
        queueBind in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueUnbind

        public com.rabbitmq.client.AMQP.Queue.UnbindOk queueUnbind​(java.lang.String queue,
                                                           java.lang.String exchange,
                                                           java.lang.String routingKey)
                                                    throws java.io.IOException
        Specified by:
        queueUnbind in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueUnbind

        public com.rabbitmq.client.AMQP.Queue.UnbindOk queueUnbind​(java.lang.String queue,
                                                           java.lang.String exchange,
                                                           java.lang.String routingKey,
                                                           java.util.Map<java.lang.String,​java.lang.Object> arguments)
                                                    throws java.io.IOException
        Specified by:
        queueUnbind in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queuePurge

        public com.rabbitmq.client.AMQP.Queue.PurgeOk queuePurge​(java.lang.String queue)
                                                  throws java.io.IOException
        Specified by:
        queuePurge in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicGet

        public com.rabbitmq.client.GetResponse basicGet​(java.lang.String queue,
                                                boolean autoAck)
                                         throws java.io.IOException
        Specified by:
        basicGet in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicAck

        public void basicAck​(long deliveryTag,
                     boolean multiple)
              throws java.io.IOException
        Specified by:
        basicAck in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicNack

        public void basicNack​(long deliveryTag,
                      boolean multiple,
                      boolean requeue)
               throws java.io.IOException
        Specified by:
        basicNack in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicReject

        public void basicReject​(long deliveryTag,
                        boolean requeue)
                 throws java.io.IOException
        Specified by:
        basicReject in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     com.rabbitmq.client.Consumer callback)
                              throws java.io.IOException
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.CancelCallback cancelCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.CancelCallback cancelCallback,
                                     com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     com.rabbitmq.client.Consumer callback)
                              throws java.io.IOException
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.CancelCallback cancelCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.CancelCallback cancelCallback,
                                     com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.lang.String consumerTag,
                                     com.rabbitmq.client.Consumer callback)
                              throws java.io.IOException
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.lang.String consumerTag,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.CancelCallback cancelCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.lang.String consumerTag,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.lang.String consumerTag,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.CancelCallback cancelCallback,
                                     com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.util.Map<java.lang.String,​java.lang.Object> arguments,
                                     com.rabbitmq.client.Consumer callback)
                              throws java.io.IOException
        Added to the 3.3.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        1.3.3

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.util.Map<java.lang.String,​java.lang.Object> arguments,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.CancelCallback cancelCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.util.Map<java.lang.String,​java.lang.Object> arguments,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.util.Map<java.lang.String,​java.lang.Object> arguments,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.CancelCallback cancelCallback,
                                     com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.lang.String consumerTag,
                                     boolean noLocal,
                                     boolean exclusive,
                                     java.util.Map<java.lang.String,​java.lang.Object> arguments,
                                     com.rabbitmq.client.Consumer callback)
                              throws java.io.IOException
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.lang.String consumerTag,
                                     boolean noLocal,
                                     boolean exclusive,
                                     java.util.Map<java.lang.String,​java.lang.Object> arguments,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.CancelCallback cancelCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.lang.String consumerTag,
                                     boolean noLocal,
                                     boolean exclusive,
                                     java.util.Map<java.lang.String,​java.lang.Object> arguments,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicConsume

        public java.lang.String basicConsume​(java.lang.String queue,
                                     boolean autoAck,
                                     java.lang.String consumerTag,
                                     boolean noLocal,
                                     boolean exclusive,
                                     java.util.Map<java.lang.String,​java.lang.Object> arguments,
                                     com.rabbitmq.client.DeliverCallback deliverCallback,
                                     com.rabbitmq.client.CancelCallback cancelCallback,
                                     com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                              throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        basicConsume in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • basicCancel

        public void basicCancel​(java.lang.String consumerTag)
                 throws java.io.IOException
        Specified by:
        basicCancel in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicRecover

        public com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover()
                                                      throws java.io.IOException
        Specified by:
        basicRecover in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • basicRecover

        public com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover​(boolean requeue)
                                                      throws java.io.IOException
        Specified by:
        basicRecover in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • txSelect

        public com.rabbitmq.client.AMQP.Tx.SelectOk txSelect()
                                              throws java.io.IOException
        Specified by:
        txSelect in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • txCommit

        public com.rabbitmq.client.AMQP.Tx.CommitOk txCommit()
                                              throws java.io.IOException
        Specified by:
        txCommit in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • txRollback

        public com.rabbitmq.client.AMQP.Tx.RollbackOk txRollback()
                                                  throws java.io.IOException
        Specified by:
        txRollback in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • confirmSelect

        public com.rabbitmq.client.AMQP.Confirm.SelectOk confirmSelect()
                                                        throws java.io.IOException
        Specified by:
        confirmSelect in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • getNextPublishSeqNo

        public long getNextPublishSeqNo()
        Specified by:
        getNextPublishSeqNo in interface com.rabbitmq.client.Channel

      • waitForConfirms

        public boolean waitForConfirms()
                        throws java.lang.InterruptedException
        Specified by:
        waitForConfirms in interface com.rabbitmq.client.Channel
        Throws:
        java.lang.InterruptedException

      • waitForConfirms

        public boolean waitForConfirms​(long timeout)
                        throws java.lang.InterruptedException,
                               java.util.concurrent.TimeoutException
        Specified by:
        waitForConfirms in interface com.rabbitmq.client.Channel
        Throws:
        java.lang.InterruptedException
        java.util.concurrent.TimeoutException

      • waitForConfirmsOrDie

        public void waitForConfirmsOrDie()
                          throws java.io.IOException,
                                 java.lang.InterruptedException
        Specified by:
        waitForConfirmsOrDie in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        java.lang.InterruptedException

      • waitForConfirmsOrDie

        public void waitForConfirmsOrDie​(long timeout)
                          throws java.io.IOException,
                                 java.lang.InterruptedException,
                                 java.util.concurrent.TimeoutException
        Specified by:
        waitForConfirmsOrDie in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        java.lang.InterruptedException
        java.util.concurrent.TimeoutException

      • asyncRpc

        public void asyncRpc​(com.rabbitmq.client.Method method)
              throws java.io.IOException
        Specified by:
        asyncRpc in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • rpc

        public com.rabbitmq.client.Command rpc​(com.rabbitmq.client.Method method)
                                throws java.io.IOException
        Specified by:
        rpc in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • addConfirmListener

        public void addConfirmListener​(com.rabbitmq.client.ConfirmListener listener)
        Specified by:
        addConfirmListener in interface com.rabbitmq.client.Channel

      • addConfirmListener

        public com.rabbitmq.client.ConfirmListener addConfirmListener​(com.rabbitmq.client.ConfirmCallback ackCallback,
                                                              com.rabbitmq.client.ConfirmCallback nackCallback)
        Specified by:
        addConfirmListener in interface com.rabbitmq.client.Channel

      • removeConfirmListener

        public boolean removeConfirmListener​(com.rabbitmq.client.ConfirmListener listener)
        Specified by:
        removeConfirmListener in interface com.rabbitmq.client.Channel

      • clearConfirmListeners

        public void clearConfirmListeners()
        Specified by:
        clearConfirmListeners in interface com.rabbitmq.client.Channel

      • addReturnListener

        public void addReturnListener​(com.rabbitmq.client.ReturnListener listener)
        Specified by:
        addReturnListener in interface com.rabbitmq.client.Channel

      • addReturnListener

        public com.rabbitmq.client.ReturnListener addReturnListener​(com.rabbitmq.client.ReturnCallback returnCallback)
        Added to the 5.0.x client.
        Specified by:
        addReturnListener in interface com.rabbitmq.client.Channel
        Since:
        2.0

      • removeReturnListener

        public boolean removeReturnListener​(com.rabbitmq.client.ReturnListener listener)
        Specified by:
        removeReturnListener in interface com.rabbitmq.client.Channel

      • clearReturnListeners

        public void clearReturnListeners()
        Specified by:
        clearReturnListeners in interface com.rabbitmq.client.Channel

      • exchangeBindNoWait

        public void exchangeBindNoWait​(java.lang.String destination,
                               java.lang.String source,
                               java.lang.String routingKey,
                               java.util.Map<java.lang.String,​java.lang.Object> arguments)
                        throws java.io.IOException
        Specified by:
        exchangeBindNoWait in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclareNoWait

        public void exchangeDeclareNoWait​(java.lang.String exchange,
                                  java.lang.String type,
                                  boolean durable,
                                  boolean autoDelete,
                                  boolean internal,
                                  java.util.Map<java.lang.String,​java.lang.Object> arguments)
                           throws java.io.IOException
        Specified by:
        exchangeDeclareNoWait in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeclareNoWait

        public void exchangeDeclareNoWait​(java.lang.String exchange,
                                  com.rabbitmq.client.BuiltinExchangeType type,
                                  boolean durable,
                                  boolean autoDelete,
                                  boolean internal,
                                  java.util.Map<java.lang.String,​java.lang.Object> arguments)
                           throws java.io.IOException
        Specified by:
        exchangeDeclareNoWait in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeDeleteNoWait

        public void exchangeDeleteNoWait​(java.lang.String exchange,
                                 boolean ifUnused)
                          throws java.io.IOException
        Specified by:
        exchangeDeleteNoWait in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • exchangeUnbindNoWait

        public void exchangeUnbindNoWait​(java.lang.String destination,
                                 java.lang.String source,
                                 java.lang.String routingKey,
                                 java.util.Map<java.lang.String,​java.lang.Object> arguments)
                          throws java.io.IOException
        Specified by:
        exchangeUnbindNoWait in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueBindNoWait

        public void queueBindNoWait​(java.lang.String queue,
                            java.lang.String exchange,
                            java.lang.String routingKey,
                            java.util.Map<java.lang.String,​java.lang.Object> arguments)
                     throws java.io.IOException
        Specified by:
        queueBindNoWait in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueDeclareNoWait

        public void queueDeclareNoWait​(java.lang.String queue,
                               boolean durable,
                               boolean exclusive,
                               boolean autoDelete,
                               java.util.Map<java.lang.String,​java.lang.Object> arguments)
                        throws java.io.IOException
        Specified by:
        queueDeclareNoWait in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • queueDeleteNoWait

        public void queueDeleteNoWait​(java.lang.String queue,
                              boolean ifUnused,
                              boolean ifEmpty)
                       throws java.io.IOException
        Specified by:
        queueDeleteNoWait in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • consumerCount

        public long consumerCount​(java.lang.String queue)
                   throws java.io.IOException
        Specified by:
        consumerCount in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • asyncCompletableRpc

        public java.util.concurrent.CompletableFuture<com.rabbitmq.client.Command> asyncCompletableRpc​(com.rabbitmq.client.Method method)
                                                                                        throws java.io.IOException
        Added to the 5.0.x client.
        Specified by:
        asyncCompletableRpc in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        Since:
        2.0

      • messageCount

        public long messageCount​(java.lang.String queue)
                  throws java.io.IOException
        Specified by:
        messageCount in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException

      • getDelegate

        public com.rabbitmq.client.Channel getDelegate()
        Description copied from interface: PublisherCallbackChannel
        Use this to invoke methods on the underlying rabbit client Channel that are not supported by this implementation.
        Specified by:
        getDelegate in interface PublisherCallbackChannel
        Returns:
        The underlying rabbit client Channel.

      • close

        public void close()
           throws java.io.IOException,
                  java.util.concurrent.TimeoutException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface com.rabbitmq.client.Channel
        Throws:
        java.io.IOException
        java.util.concurrent.TimeoutException

      • handleAck

        public void handleAck​(long seq,
                      boolean multiple)
        Specified by:
        handleAck in interface com.rabbitmq.client.ConfirmListener

      • handleNack

        public void handleNack​(long seq,
                       boolean multiple)
        Specified by:
        handleNack in interface com.rabbitmq.client.ConfirmListener

      • handle

        public void handle​(com.rabbitmq.client.Return returned)
        Specified by:
        handle in interface com.rabbitmq.client.ReturnCallback

      • shutdownCompleted

        public void shutdownCompleted​(com.rabbitmq.client.ShutdownSignalException cause)
        Specified by:
        shutdownCompleted in interface com.rabbitmq.client.ShutdownListener

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object

      • equals

        public boolean equals​(java.lang.Object obj)
        Overrides:
        equals in class java.lang.Object

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object