クラス PublisherCallbackChannelImpl

  • 実装されたすべてのインターフェース:
    com.rabbitmq.client.Channelcom.rabbitmq.client.ConfirmListenercom.rabbitmq.client.ReturnCallbackcom.rabbitmq.client.ShutdownListenercom.rabbitmq.client.ShutdownNotifierAutoCloseableSEEventListenerSEPublisherCallbackChannel

    public class PublisherCallbackChannelImpl
    extends ObjectSE
    implements PublisherCallbackChannel, com.rabbitmq.client.ConfirmListener, com.rabbitmq.client.ReturnCallback, com.rabbitmq.client.ShutdownListener
    単一のリスナーが複数のチャネルからの確認を処理できるようにするチャネルラッパー。
    導入:
    1.0.1
    作成者:
    Gary Russell, Arnaud Cogolu è gnes, Artem Bilan
    • コンストラクターの詳細

      • PublisherCallbackChannelImpl

        public PublisherCallbackChannelImpl​(com.rabbitmq.client.Channel delegate,
                                            ExecutorServiceSE executor)
        提供されたデリゲートとエグゼキューターに基づいて PublisherCallbackChannelImpl インスタンスを作成します。
        パラメーター:
        delegate - 代理チャンネル。
        executor - 執行者。
    • メソッドの詳細

      • setAfterAckCallback

        public void setAfterAckCallback​(ConsumerSE<com.rabbitmq.client.Channel> callback)
        インターフェースからコピーされた説明: PublisherCallbackChannel
        ack/nack が処理された後に呼び出されるコールバックを設定します。
        次で指定:
        インターフェース PublisherCallbackChannelsetAfterAckCallback 
        パラメーター:
        callback - コールバック。
      • addShutdownListener

        public void addShutdownListener​(com.rabbitmq.client.ShutdownListener listener)
        次で指定:
        インターフェース com.rabbitmq.client.ShutdownNotifieraddShutdownListener 
      • removeShutdownListener

        public void removeShutdownListener​(com.rabbitmq.client.ShutdownListener listener)
        次で指定:
        インターフェース com.rabbitmq.client.ShutdownNotifierremoveShutdownListener 
      • getCloseReason

        public com.rabbitmq.client.ShutdownSignalException getCloseReason()
        次で指定:
        インターフェース com.rabbitmq.client.ShutdownNotifiergetCloseReason 
      • notifyListeners

        public void notifyListeners()
        次で指定:
        インターフェース com.rabbitmq.client.ShutdownNotifiernotifyListeners 
      • isOpen

        public boolean isOpen()
        次で指定:
        インターフェース com.rabbitmq.client.ShutdownNotifierisOpen 
      • getChannelNumber

        public int getChannelNumber()
        次で指定:
        インターフェース com.rabbitmq.client.ChannelgetChannelNumber 
      • getConnection

        public com.rabbitmq.client.Connection getConnection()
        次で指定:
        インターフェース com.rabbitmq.client.ChannelgetConnection 
      • abort

        public void abort()
                   throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.Channelabort 
        例外:
        IOExceptionSE
      • abort

        public void abort​(int closeCode,
                          StringSE closeMessage)
                   throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.Channelabort 
        例外:
        IOExceptionSE
      • getDefaultConsumer

        public com.rabbitmq.client.Consumer getDefaultConsumer()
        次で指定:
        インターフェース com.rabbitmq.client.ChannelgetDefaultConsumer 
      • setDefaultConsumer

        public void setDefaultConsumer​(com.rabbitmq.client.Consumer consumer)
        次で指定:
        インターフェース com.rabbitmq.client.ChannelsetDefaultConsumer 
      • basicQos

        public void basicQos​(int prefetchSize,
                             int prefetchCount,
                             boolean global)
                      throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicQos 
        例外:
        IOExceptionSE
      • basicQos

        public void basicQos​(int prefetchCount,
                             boolean global)
                      throws IOExceptionSE
        3.3.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicQos 
        例外:
        IOExceptionSE
        導入:
        1.3.3
      • basicQos

        public void basicQos​(int prefetchCount)
                      throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicQos 
        例外:
        IOExceptionSE
      • basicPublish

        public void basicPublish​(StringSE exchange,
                                 StringSE routingKey,
                                 com.rabbitmq.client.AMQP.BasicProperties props,
                                 byte[] body)
                          throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicPublish 
        例外:
        IOExceptionSE
      • basicPublish

        public void basicPublish​(StringSE exchange,
                                 StringSE routingKey,
                                 boolean mandatory,
                                 boolean immediate,
                                 com.rabbitmq.client.AMQP.BasicProperties props,
                                 byte[] body)
                          throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicPublish 
        例外:
        IOExceptionSE
      • basicPublish

        public void basicPublish​(StringSE exchange,
                                 StringSE routingKey,
                                 boolean mandatory,
                                 com.rabbitmq.client.AMQP.BasicProperties props,
                                 byte[] body)
                          throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicPublish 
        例外:
        IOExceptionSE
      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(StringSE exchange,
                                                                           StringSE type)
                                                                    throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclare 
        例外:
        IOExceptionSE
      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(StringSE exchange,
                                                                           com.rabbitmq.client.BuiltinExchangeType type)
                                                                    throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclare 
        例外:
        IOExceptionSE
      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(StringSE exchange,
                                                                           StringSE type,
                                                                           boolean durable)
                                                                    throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclare 
        例外:
        IOExceptionSE
      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(StringSE exchange,
                                                                           com.rabbitmq.client.BuiltinExchangeType type,
                                                                           boolean durable)
                                                                    throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclare 
        例外:
        IOExceptionSE
      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(StringSE exchange,
                                                                           StringSE type,
                                                                           boolean durable,
                                                                           boolean autoDelete,
                                                                           MapSE<StringSE,​ObjectSE> arguments)
                                                                    throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclare 
        例外:
        IOExceptionSE
      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(StringSE exchange,
                                                                           com.rabbitmq.client.BuiltinExchangeType type,
                                                                           boolean durable,
                                                                           boolean autoDelete,
                                                                           MapSE<StringSE,​ObjectSE> arguments)
                                                                    throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclare 
        例外:
        IOExceptionSE
      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(StringSE exchange,
                                                                           StringSE type,
                                                                           boolean durable,
                                                                           boolean autoDelete,
                                                                           boolean internal,
                                                                           MapSE<StringSE,​ObjectSE> arguments)
                                                                    throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclare 
        例外:
        IOExceptionSE
      • exchangeDeclare

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare​(StringSE exchange,
                                                                           com.rabbitmq.client.BuiltinExchangeType type,
                                                                           boolean durable,
                                                                           boolean autoDelete,
                                                                           boolean internal,
                                                                           MapSE<StringSE,​ObjectSE> arguments)
                                                                    throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclare 
        例外:
        IOExceptionSE
      • exchangeDeclarePassive

        public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclarePassive​(StringSE name)
                                                                           throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclarePassive 
        例外:
        IOExceptionSE
      • exchangeDelete

        public com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete​(StringSE exchange,
                                                                         boolean ifUnused)
                                                                  throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDelete 
        例外:
        IOExceptionSE
      • exchangeDelete

        public com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete​(StringSE exchange)
                                                                  throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDelete 
        例外:
        IOExceptionSE
      • exchangeBind

        public com.rabbitmq.client.AMQP.Exchange.BindOk exchangeBind​(StringSE destination,
                                                                     StringSE source,
                                                                     StringSE routingKey)
                                                              throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeBind 
        例外:
        IOExceptionSE
      • exchangeUnbind

        public com.rabbitmq.client.AMQP.Exchange.UnbindOk exchangeUnbind​(StringSE destination,
                                                                         StringSE source,
                                                                         StringSE routingKey)
                                                                  throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeUnbind 
        例外:
        IOExceptionSE
      • queueDeclare

        public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare()
                                                              throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelqueueDeclare 
        例外:
        IOExceptionSE
      • queueDeclare

        public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare​(StringSE queue,
                                                                     boolean durable,
                                                                     boolean exclusive,
                                                                     boolean autoDelete,
                                                                     MapSE<StringSE,​ObjectSE> arguments)
                                                              throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelqueueDeclare 
        例外:
        IOExceptionSE
      • queueDeclarePassive

        public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclarePassive​(StringSE queue)
                                                                     throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelqueueDeclarePassive 
        例外:
        IOExceptionSE
      • queueDelete

        public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete​(StringSE queue)
                                                            throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelqueueDelete 
        例外:
        IOExceptionSE
      • queueDelete

        public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete​(StringSE queue,
                                                                   boolean ifUnused,
                                                                   boolean ifEmpty)
                                                            throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelqueueDelete 
        例外:
        IOExceptionSE
      • queueBind

        public com.rabbitmq.client.AMQP.Queue.BindOk queueBind​(StringSE queue,
                                                               StringSE exchange,
                                                               StringSE routingKey)
                                                        throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelqueueBind 
        例外:
        IOExceptionSE
      • queueUnbind

        public com.rabbitmq.client.AMQP.Queue.UnbindOk queueUnbind​(StringSE queue,
                                                                   StringSE exchange,
                                                                   StringSE routingKey)
                                                            throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelqueueUnbind 
        例外:
        IOExceptionSE
      • queuePurge

        public com.rabbitmq.client.AMQP.Queue.PurgeOk queuePurge​(StringSE queue)
                                                          throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelqueuePurge 
        例外:
        IOExceptionSE
      • basicGet

        public com.rabbitmq.client.GetResponse basicGet​(StringSE queue,
                                                        boolean autoAck)
                                                 throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicGet 
        例外:
        IOExceptionSE
      • basicAck

        public void basicAck​(long deliveryTag,
                             boolean multiple)
                      throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicAck 
        例外:
        IOExceptionSE
      • basicNack

        public void basicNack​(long deliveryTag,
                              boolean multiple,
                              boolean requeue)
                       throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicNack 
        例外:
        IOExceptionSE
      • basicReject

        public void basicReject​(long deliveryTag,
                                boolean requeue)
                         throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicReject 
        例外:
        IOExceptionSE
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   com.rabbitmq.client.Consumer callback)
                            throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.CancelCallback cancelCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.CancelCallback cancelCallback,
                                   com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   com.rabbitmq.client.Consumer callback)
                            throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.CancelCallback cancelCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.CancelCallback cancelCallback,
                                   com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   StringSE consumerTag,
                                   com.rabbitmq.client.Consumer callback)
                            throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   StringSE consumerTag,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.CancelCallback cancelCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   StringSE consumerTag,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   StringSE consumerTag,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.CancelCallback cancelCallback,
                                   com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   MapSE<StringSE,​ObjectSE> arguments,
                                   com.rabbitmq.client.Consumer callback)
                            throws IOExceptionSE
        3.3.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        1.3.3
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   MapSE<StringSE,​ObjectSE> arguments,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.CancelCallback cancelCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   MapSE<StringSE,​ObjectSE> arguments,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   MapSE<StringSE,​ObjectSE> arguments,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.CancelCallback cancelCallback,
                                   com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   StringSE consumerTag,
                                   boolean noLocal,
                                   boolean exclusive,
                                   MapSE<StringSE,​ObjectSE> arguments,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.CancelCallback cancelCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   StringSE consumerTag,
                                   boolean noLocal,
                                   boolean exclusive,
                                   MapSE<StringSE,​ObjectSE> arguments,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicConsume

        public StringSE basicConsume​(StringSE queue,
                                   boolean autoAck,
                                   StringSE consumerTag,
                                   boolean noLocal,
                                   boolean exclusive,
                                   MapSE<StringSE,​ObjectSE> arguments,
                                   com.rabbitmq.client.DeliverCallback deliverCallback,
                                   com.rabbitmq.client.CancelCallback cancelCallback,
                                   com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                            throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicConsume 
        例外:
        IOExceptionSE
        導入:
        2.0
      • basicCancel

        public void basicCancel​(StringSE consumerTag)
                         throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicCancel 
        例外:
        IOExceptionSE
      • basicRecover

        public com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover()
                                                              throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicRecover 
        例外:
        IOExceptionSE
      • basicRecover

        public com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover​(boolean requeue)
                                                              throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelbasicRecover 
        例外:
        IOExceptionSE
      • txSelect

        public com.rabbitmq.client.AMQP.Tx.SelectOk txSelect()
                                                      throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChanneltxSelect 
        例外:
        IOExceptionSE
      • txCommit

        public com.rabbitmq.client.AMQP.Tx.CommitOk txCommit()
                                                      throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChanneltxCommit 
        例外:
        IOExceptionSE
      • txRollback

        public com.rabbitmq.client.AMQP.Tx.RollbackOk txRollback()
                                                          throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChanneltxRollback 
        例外:
        IOExceptionSE
      • confirmSelect

        public com.rabbitmq.client.AMQP.Confirm.SelectOk confirmSelect()
                                                                throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelconfirmSelect 
        例外:
        IOExceptionSE
      • getNextPublishSeqNo

        public long getNextPublishSeqNo()
        次で指定:
        インターフェース com.rabbitmq.client.ChannelgetNextPublishSeqNo 
      • asyncRpc

        public void asyncRpc​(com.rabbitmq.client.Method method)
                      throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelasyncRpc 
        例外:
        IOExceptionSE
      • rpc

        public com.rabbitmq.client.Command rpc​(com.rabbitmq.client.Method method)
                                        throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.Channelrpc 
        例外:
        IOExceptionSE
      • addConfirmListener

        public void addConfirmListener​(com.rabbitmq.client.ConfirmListener listener)
        次で指定:
        インターフェース com.rabbitmq.client.ChanneladdConfirmListener 
      • addConfirmListener

        public com.rabbitmq.client.ConfirmListener addConfirmListener​(com.rabbitmq.client.ConfirmCallback ackCallback,
                                                                      com.rabbitmq.client.ConfirmCallback nackCallback)
        次で指定:
        インターフェース com.rabbitmq.client.ChanneladdConfirmListener 
      • removeConfirmListener

        public boolean removeConfirmListener​(com.rabbitmq.client.ConfirmListener listener)
        次で指定:
        インターフェース com.rabbitmq.client.ChannelremoveConfirmListener 
      • clearConfirmListeners

        public void clearConfirmListeners()
        次で指定:
        インターフェース com.rabbitmq.client.ChannelclearConfirmListeners 
      • addReturnListener

        public void addReturnListener​(com.rabbitmq.client.ReturnListener listener)
        次で指定:
        インターフェース com.rabbitmq.client.ChanneladdReturnListener 
      • addReturnListener

        public com.rabbitmq.client.ReturnListener addReturnListener​(com.rabbitmq.client.ReturnCallback returnCallback)
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChanneladdReturnListener 
        導入:
        2.0
      • removeReturnListener

        public boolean removeReturnListener​(com.rabbitmq.client.ReturnListener listener)
        次で指定:
        インターフェース com.rabbitmq.client.ChannelremoveReturnListener 
      • clearReturnListeners

        public void clearReturnListeners()
        次で指定:
        インターフェース com.rabbitmq.client.ChannelclearReturnListeners 
      • exchangeDeclareNoWait

        public void exchangeDeclareNoWait​(StringSE exchange,
                                          StringSE type,
                                          boolean durable,
                                          boolean autoDelete,
                                          boolean internal,
                                          MapSE<StringSE,​ObjectSE> arguments)
                                   throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclareNoWait 
        例外:
        IOExceptionSE
      • exchangeDeclareNoWait

        public void exchangeDeclareNoWait​(StringSE exchange,
                                          com.rabbitmq.client.BuiltinExchangeType type,
                                          boolean durable,
                                          boolean autoDelete,
                                          boolean internal,
                                          MapSE<StringSE,​ObjectSE> arguments)
                                   throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeclareNoWait 
        例外:
        IOExceptionSE
      • exchangeDeleteNoWait

        public void exchangeDeleteNoWait​(StringSE exchange,
                                         boolean ifUnused)
                                  throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelexchangeDeleteNoWait 
        例外:
        IOExceptionSE
      • queueDeclareNoWait

        public void queueDeclareNoWait​(StringSE queue,
                                       boolean durable,
                                       boolean exclusive,
                                       boolean autoDelete,
                                       MapSE<StringSE,​ObjectSE> arguments)
                                throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelqueueDeclareNoWait 
        例外:
        IOExceptionSE
      • queueDeleteNoWait

        public void queueDeleteNoWait​(StringSE queue,
                                      boolean ifUnused,
                                      boolean ifEmpty)
                               throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelqueueDeleteNoWait 
        例外:
        IOExceptionSE
      • consumerCount

        public long consumerCount​(StringSE queue)
                           throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelconsumerCount 
        例外:
        IOExceptionSE
      • asyncCompletableRpc

        public CompletableFutureSE<com.rabbitmq.client.Command> asyncCompletableRpc​(com.rabbitmq.client.Method method)
                                                                           throws IOExceptionSE
        5.0.x クライアントに追加されました。
        次で指定:
        インターフェース com.rabbitmq.client.ChannelasyncCompletableRpc 
        例外:
        IOExceptionSE
        導入:
        2.0
      • messageCount

        public long messageCount​(StringSE queue)
                          throws IOExceptionSE
        次で指定:
        インターフェース com.rabbitmq.client.ChannelmessageCount 
        例外:
        IOExceptionSE
      • getDelegate

        public com.rabbitmq.client.Channel getDelegate()
        インターフェースからコピーされた説明: PublisherCallbackChannel
        これを使用して、この実装ではサポートされていない、基礎となる rabbit クライアント Channel のメソッドを呼び出します。
        次で指定:
        インターフェース PublisherCallbackChannelgetDelegate 
        戻り値:
        基盤となる rabbit クライアント Channel
      • handleAck

        public void handleAck​(long seq,
                              boolean multiple)
        次で指定:
        インターフェース com.rabbitmq.client.ConfirmListenerhandleAck 
      • handleNack

        public void handleNack​(long seq,
                               boolean multiple)
        次で指定:
        インターフェース com.rabbitmq.client.ConfirmListenerhandleNack 
      • handle

        public void handle​(com.rabbitmq.client.Return returned)
        次で指定:
        インターフェース com.rabbitmq.client.ReturnCallbackhandle 
      • shutdownCompleted

        public void shutdownCompleted​(com.rabbitmq.client.ShutdownSignalException cause)
        次で指定:
        インターフェース com.rabbitmq.client.ShutdownListenershutdownCompleted 
      • hashCode

        public int hashCode()
        オーバーライド:
        クラス ObjectSEhashCode