クラス PublisherCallbackChannelImpl

java.lang.ObjectSE
org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
実装されているすべてのインターフェース:
com.rabbitmq.client.Channel、com.rabbitmq.client.ConfirmListener、com.rabbitmq.client.ReturnCallback、com.rabbitmq.client.ShutdownListener、com.rabbitmq.client.ShutdownNotifier、AutoCloseableSE、EventListenerSE、PublisherCallbackChannel
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, Christian Tzolov, Ngoc Nhan

  • コンストラクターの詳細

    • 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 が処理された後に呼び出されるコールバックを設定します。
      次で指定:
      インターフェース PublisherCallbackChannel の setAfterAckCallback 
      パラメーター:
      callback - コールバック。

    • addShutdownListener

      public void addShutdownListener(com.rabbitmq.client.ShutdownListener listener)
      ///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
      次で指定:
      インターフェース com.rabbitmq.client.ShutdownNotifier の addShutdownListener 

    • removeShutdownListener

      public void removeShutdownListener(com.rabbitmq.client.ShutdownListener listener)
      次で指定:
      インターフェース com.rabbitmq.client.ShutdownNotifier の removeShutdownListener 

    • getCloseReason

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

    • notifyListeners

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

    • isOpen

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

    • getChannelNumber

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

    • getConnection

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

    • close

      public void close(int closeCode, StringSE closeMessage) throws IOExceptionSE, TimeoutExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の close 
      例外:
      IOExceptionSE
      TimeoutExceptionSE

    • abort

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

    • abort

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

    • getDefaultConsumer

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

    • setDefaultConsumer

      public void setDefaultConsumer(com.rabbitmq.client.Consumer consumer)
      次で指定:
      インターフェース com.rabbitmq.client.Channel の setDefaultConsumer 

    • basicQos

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

    • basicQos

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

    • basicQos

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

    • basicPublish

      public void basicPublish(StringSE exchange, StringSE routingKey, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の basicPublish 
      例外:
      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.Channel の basicPublish 
      例外:
      IOExceptionSE

    • basicPublish

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

    • exchangeDeclare

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

    • exchangeDeclare

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

    • exchangeDeclare

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

    • exchangeDeclare

      public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の exchangeDeclare 
      例外:
      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.Channel の exchangeDeclare 
      例外:
      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.Channel の exchangeDeclare 
      例外:
      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.Channel の exchangeDeclare 
      例外:
      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.Channel の exchangeDeclare 
      例外:
      IOExceptionSE

    • exchangeDeclarePassive

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

    • exchangeDelete

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

    • exchangeDelete

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

    • exchangeBind

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

    • exchangeBind

      public com.rabbitmq.client.AMQP.Exchange.BindOk exchangeBind(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の exchangeBind 
      例外:
      IOExceptionSE

    • exchangeUnbind

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

    • exchangeUnbind

      public com.rabbitmq.client.AMQP.Exchange.UnbindOk exchangeUnbind(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の exchangeUnbind 
      例外:
      IOExceptionSE

    • queueDeclare

      public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare() throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の queueDeclare 
      例外:
      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.Channel の queueDeclare 
      例外:
      IOExceptionSE

    • queueDeclarePassive

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

    • queueDelete

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

    • queueDelete

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

    • queueBind

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

    • queueBind

      public com.rabbitmq.client.AMQP.Queue.BindOk queueBind(StringSE queue, StringSE exchange, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の queueBind 
      例外:
      IOExceptionSE

    • queueUnbind

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

    • queueUnbind

      public com.rabbitmq.client.AMQP.Queue.UnbindOk queueUnbind(StringSE queue, StringSE exchange, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の queueUnbind 
      例外:
      IOExceptionSE

    • queuePurge

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

    • basicGet

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

    • basicAck

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

    • basicNack

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

    • basicReject

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

    • basicConsume

      public StringSE basicConsume(StringSE queue, com.rabbitmq.client.Consumer callback) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      IOExceptionSE
      導入:
      2.0

    • basicConsume

      public StringSE basicConsume(StringSE queue, boolean autoAck, com.rabbitmq.client.Consumer callback) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      IOExceptionSE
      導入:
      2.0

    • basicConsume

      public StringSE basicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, com.rabbitmq.client.Consumer callback) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      IOExceptionSE
      導入:
      2.0

    • basicConsume

      public StringSE basicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, boolean noLocal, boolean exclusive, MapSE<StringSE,ObjectSE> arguments, com.rabbitmq.client.Consumer callback) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の basicConsume 
      例外:
      IOExceptionSE

    • 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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      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.Channel の basicConsume 
      例外:
      IOExceptionSE
      導入:
      2.0

    • basicCancel

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

    • basicRecover

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

    • basicRecover

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

    • txSelect

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

    • txCommit

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

    • txRollback

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

    • confirmSelect

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

    • getNextPublishSeqNo

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

    • waitForConfirms

      public boolean waitForConfirms() throws InterruptedExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の waitForConfirms 
      例外:
      InterruptedExceptionSE

    • waitForConfirms

      public boolean waitForConfirms(long timeout) throws InterruptedExceptionSE, TimeoutExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の waitForConfirms 
      例外:
      InterruptedExceptionSE
      TimeoutExceptionSE

    • waitForConfirmsOrDie

      public void waitForConfirmsOrDie() throws IOExceptionSE, InterruptedExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の waitForConfirmsOrDie 
      例外:
      IOExceptionSE
      InterruptedExceptionSE

    • waitForConfirmsOrDie

      public void waitForConfirmsOrDie(long timeout) throws IOExceptionSE, InterruptedExceptionSE, TimeoutExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の waitForConfirmsOrDie 
      例外:
      IOExceptionSE
      InterruptedExceptionSE
      TimeoutExceptionSE

    • asyncRpc

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

    • rpc

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

    • addConfirmListener

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

    • addConfirmListener

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

    • removeConfirmListener

      public boolean removeConfirmListener(com.rabbitmq.client.ConfirmListener listener)
      次で指定:
      インターフェース com.rabbitmq.client.Channel の removeConfirmListener 

    • clearConfirmListeners

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

    • addReturnListener

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

    • addReturnListener

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

    • removeReturnListener

      public boolean removeReturnListener(com.rabbitmq.client.ReturnListener listener)
      次で指定:
      インターフェース com.rabbitmq.client.Channel の removeReturnListener 

    • clearReturnListeners

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

    • exchangeBindNoWait

      public void exchangeBindNoWait(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の exchangeBindNoWait 
      例外:
      IOExceptionSE

    • exchangeDeclareNoWait

      public void exchangeDeclareNoWait(StringSE exchange, StringSE type, boolean durable, boolean autoDelete, boolean internal, MapSE<StringSE,ObjectSE> arguments) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の exchangeDeclareNoWait 
      例外:
      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.Channel の exchangeDeclareNoWait 
      例外:
      IOExceptionSE

    • exchangeDeleteNoWait

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

    • exchangeUnbindNoWait

      public void exchangeUnbindNoWait(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の exchangeUnbindNoWait 
      例外:
      IOExceptionSE

    • queueBindNoWait

      public void queueBindNoWait(StringSE queue, StringSE exchange, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments) throws IOExceptionSE
      次で指定:
      インターフェース com.rabbitmq.client.Channel の queueBindNoWait 
      例外:
      IOExceptionSE

    • queueDeclareNoWait

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

    • queueDeleteNoWait

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

    • consumerCount

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

    • asyncCompletableRpc

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

    • messageCount

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

    • getDelegate

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

    • close

      public void close() throws IOExceptionSE, TimeoutExceptionSE
      ///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
      次で指定:
      インターフェース AutoCloseableSE の close 
      次で指定:
      インターフェース com.rabbitmq.client.Channel の close 
      例外:
      IOExceptionSE
      TimeoutExceptionSE

    • getPendingConfirmsCount

      public int getPendingConfirmsCount(PublisherCallbackChannel.Listener listener)
      インターフェースからコピーされた説明: PublisherCallbackChannel
      PendingConfirm のカウントを取得します。
      次で指定:
      インターフェース PublisherCallbackChannel の getPendingConfirmsCount 
      パラメーター:
      listener - リスナー。
      戻り値:
      保留中の確認の数。

    • getPendingConfirmsCount

      public int getPendingConfirmsCount()
      インターフェースからコピーされた説明: PublisherCallbackChannel
      保留中の合計確認数を取得します。
      次で指定:
      インターフェース PublisherCallbackChannel の getPendingConfirmsCount 
      戻り値:
      カウント。

    • addListener

      public void addListener(PublisherCallbackChannel.Listener listener)
      リスナーを追加し、そのリスナーの保留中の確認の内部マップを返します。
      次で指定:
      インターフェース PublisherCallbackChannel の addListener 
      パラメーター:
      listener - リスナー。

    • expire

      public CollectionSE<PendingConfirm> expire(PublisherCallbackChannel.Listener listener, long cutoffTime)
      インターフェースからコピーされた説明: PublisherCallbackChannel
      指定されたリスナーの cutoffTime より前に作成された PendingConfirm をすべて期限切れ (削除) にして、呼び出し元に返します。
      次で指定:
      インターフェース PublisherCallbackChannel の expire 
      パラメーター:
      listener - リスナー。
      cutoffTime - 期限切れのメッセージが作成される前の時間。
      戻り値:
      期限切れの確認のリスト。

    • handleAck

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

    • handleNack

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

    • addPendingConfirm

      public void addPendingConfirm(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm)
      インターフェースからコピーされた説明: PublisherCallbackChannel
      保留中の確認をこのチャネルのマップに追加します。
      次で指定:
      インターフェース PublisherCallbackChannel の addPendingConfirm 
      パラメーター:
      listener - リスナー。
      seq - マップの鍵。
      pendingConfirm - PendingConfirm オブジェクト。

    • handle

      public void handle(com.rabbitmq.client.Return returned)
      次で指定:
      インターフェース com.rabbitmq.client.ReturnCallback の handle 

    • shutdownCompleted

      public void shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause)
      次で指定:
      インターフェース com.rabbitmq.client.ShutdownListener の shutdownCompleted 

    • hashCode

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

    • equals

      public boolean equals(ObjectSE obj)
      オーバーライド:
      クラス ObjectSE の equalsSE 

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString 

    • factory

      public static PublisherCallbackChannelFactory factory()