クラス PublisherCallbackChannelImpl

方法の詳細

• 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()