クラス 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
ネストされたクラスのサマリー
インターフェース org.springframework.amqp.rabbit.connection.PublisherCallbackChannel から継承されたネストクラス / インターフェース
PublisherCallbackChannel.Listener
フィールドサマリー
インターフェース org.springframework.amqp.rabbit.connection.PublisherCallbackChannel から継承されたフィールド
RETURN_LISTENER_CORRELATION_KEY, RETURNED_MESSAGE_CORRELATION_KEY
コンストラクターのサマリー
コンストラクター コンストラクター 説明 PublisherCallbackChannelImpl(com.rabbitmq.client.Channel delegate, ExecutorServiceSE executor)
提供されたデリゲートとエグゼキューターに基づいてPublisherCallbackChannelImpl
インスタンスを作成します。
メソッドのサマリー
すべてのメソッド 静的メソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 void
abort()
void
abort(int closeCode, StringSE closeMessage)
com.rabbitmq.client.ConfirmListener
addConfirmListener(com.rabbitmq.client.ConfirmCallback ackCallback, com.rabbitmq.client.ConfirmCallback nackCallback)
void
addConfirmListener(com.rabbitmq.client.ConfirmListener listener)
void
addListener(PublisherCallbackChannel.Listener listener)
リスナーを追加し、そのリスナーの保留中の確認の内部マップを返します。void
addPendingConfirm(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm)
保留中の確認をこのチャネルのマップに追加します。com.rabbitmq.client.ReturnListener
addReturnListener(com.rabbitmq.client.ReturnCallback returnCallback)
5.0.x クライアントに追加されました。void
addReturnListener(com.rabbitmq.client.ReturnListener listener)
void
addShutdownListener(com.rabbitmq.client.ShutdownListener listener)
CompletableFutureSE<com.rabbitmq.client.Command>
asyncCompletableRpc(com.rabbitmq.client.Method method)
5.0.x クライアントに追加されました。void
asyncRpc(com.rabbitmq.client.Method method)
void
basicAck(long deliveryTag, boolean multiple)
void
basicCancel(StringSE consumerTag)
StringSE
basicConsume(StringSE queue, boolean autoAck, com.rabbitmq.client.Consumer callback)
StringSE
basicConsume(StringSE queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, boolean noLocal, boolean exclusive, MapSE<StringSE,ObjectSE> arguments, com.rabbitmq.client.Consumer callback)
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)
5.0.x クライアントに追加されました。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)
5.0.x クライアントに追加されました。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)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, com.rabbitmq.client.Consumer callback)
StringSE
basicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, boolean autoAck, MapSE<StringSE,ObjectSE> arguments, com.rabbitmq.client.Consumer callback)
3.3.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, boolean autoAck, MapSE<StringSE,ObjectSE> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)
5.0.x クライアントに追加されました。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)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, boolean autoAck, MapSE<StringSE,ObjectSE> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, com.rabbitmq.client.Consumer callback)
StringSE
basicConsume(StringSE queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
5.0.x クライアントに追加されました。StringSE
basicConsume(StringSE queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
5.0.x クライアントに追加されました。com.rabbitmq.client.GetResponse
basicGet(StringSE queue, boolean autoAck)
void
basicNack(long deliveryTag, boolean multiple, boolean requeue)
void
basicPublish(StringSE exchange, StringSE routingKey, boolean mandatory, boolean immediate, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body)
void
basicPublish(StringSE exchange, StringSE routingKey, boolean mandatory, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body)
void
basicPublish(StringSE exchange, StringSE routingKey, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body)
void
basicQos(int prefetchCount)
void
basicQos(int prefetchCount, boolean global)
3.3.x クライアントに追加されました。void
basicQos(int prefetchSize, int prefetchCount, boolean global)
com.rabbitmq.client.AMQP.Basic.RecoverOk
basicRecover()
com.rabbitmq.client.AMQP.Basic.RecoverOk
basicRecover(boolean requeue)
void
basicReject(long deliveryTag, boolean requeue)
void
clearConfirmListeners()
void
clearReturnListeners()
void
close()
void
close(int closeCode, StringSE closeMessage)
com.rabbitmq.client.AMQP.Confirm.SelectOk
confirmSelect()
long
consumerCount(StringSE queue)
boolean
equals(ObjectSE obj)
com.rabbitmq.client.AMQP.Exchange.BindOk
exchangeBind(StringSE destination, StringSE source, StringSE routingKey)
com.rabbitmq.client.AMQP.Exchange.BindOk
exchangeBind(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)
void
exchangeBindNoWait(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)
com.rabbitmq.client.AMQP.Exchange.DeclareOk
exchangeDeclare(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type)
com.rabbitmq.client.AMQP.Exchange.DeclareOk
exchangeDeclare(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable)
com.rabbitmq.client.AMQP.Exchange.DeclareOk
exchangeDeclare(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, MapSE<StringSE,ObjectSE> arguments)
com.rabbitmq.client.AMQP.Exchange.DeclareOk
exchangeDeclare(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, MapSE<StringSE,ObjectSE> arguments)
com.rabbitmq.client.AMQP.Exchange.DeclareOk
exchangeDeclare(StringSE exchange, StringSE type)
com.rabbitmq.client.AMQP.Exchange.DeclareOk
exchangeDeclare(StringSE exchange, StringSE type, boolean durable)
com.rabbitmq.client.AMQP.Exchange.DeclareOk
exchangeDeclare(StringSE exchange, StringSE type, boolean durable, boolean autoDelete, boolean internal, MapSE<StringSE,ObjectSE> arguments)
com.rabbitmq.client.AMQP.Exchange.DeclareOk
exchangeDeclare(StringSE exchange, StringSE type, boolean durable, boolean autoDelete, MapSE<StringSE,ObjectSE> arguments)
void
exchangeDeclareNoWait(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, MapSE<StringSE,ObjectSE> arguments)
void
exchangeDeclareNoWait(StringSE exchange, StringSE type, boolean durable, boolean autoDelete, boolean internal, MapSE<StringSE,ObjectSE> arguments)
com.rabbitmq.client.AMQP.Exchange.DeclareOk
exchangeDeclarePassive(StringSE name)
com.rabbitmq.client.AMQP.Exchange.DeleteOk
exchangeDelete(StringSE exchange)
com.rabbitmq.client.AMQP.Exchange.DeleteOk
exchangeDelete(StringSE exchange, boolean ifUnused)
void
exchangeDeleteNoWait(StringSE exchange, boolean ifUnused)
com.rabbitmq.client.AMQP.Exchange.UnbindOk
exchangeUnbind(StringSE destination, StringSE source, StringSE routingKey)
com.rabbitmq.client.AMQP.Exchange.UnbindOk
exchangeUnbind(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)
void
exchangeUnbindNoWait(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)
CollectionSE<PendingConfirm>
expire(PublisherCallbackChannel.Listener listener, long cutoffTime)
指定されたリスナーの cutoffTime より前に作成されたPendingConfirm
を期限切れ (削除) し、呼び出し元に返します。static PublisherCallbackChannelFactory
factory()
int
getChannelNumber()
com.rabbitmq.client.ShutdownSignalException
getCloseReason()
com.rabbitmq.client.Connection
getConnection()
com.rabbitmq.client.Consumer
getDefaultConsumer()
com.rabbitmq.client.Channel
getDelegate()
これを使用して、この実装ではサポートされていない、基礎となる rabbit クライアントChannel
のメソッドを呼び出します。long
getNextPublishSeqNo()
int
getPendingConfirmsCount()
保留中の合計確認数を取得します。int
getPendingConfirmsCount(PublisherCallbackChannel.Listener listener)
PendingConfirm
のカウントを取得します。void
handle(com.rabbitmq.client.Return returned)
void
handleAck(long seq, boolean multiple)
void
handleNack(long seq, boolean multiple)
int
hashCode()
boolean
isOpen()
long
messageCount(StringSE queue)
void
notifyListeners()
com.rabbitmq.client.AMQP.Queue.BindOk
queueBind(StringSE queue, StringSE exchange, StringSE routingKey)
com.rabbitmq.client.AMQP.Queue.BindOk
queueBind(StringSE queue, StringSE exchange, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)
void
queueBindNoWait(StringSE queue, StringSE exchange, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)
com.rabbitmq.client.AMQP.Queue.DeclareOk
queueDeclare()
com.rabbitmq.client.AMQP.Queue.DeclareOk
queueDeclare(StringSE queue, boolean durable, boolean exclusive, boolean autoDelete, MapSE<StringSE,ObjectSE> arguments)
void
queueDeclareNoWait(StringSE queue, boolean durable, boolean exclusive, boolean autoDelete, MapSE<StringSE,ObjectSE> arguments)
com.rabbitmq.client.AMQP.Queue.DeclareOk
queueDeclarePassive(StringSE queue)
com.rabbitmq.client.AMQP.Queue.DeleteOk
queueDelete(StringSE queue)
com.rabbitmq.client.AMQP.Queue.DeleteOk
queueDelete(StringSE queue, boolean ifUnused, boolean ifEmpty)
void
queueDeleteNoWait(StringSE queue, boolean ifUnused, boolean ifEmpty)
com.rabbitmq.client.AMQP.Queue.PurgeOk
queuePurge(StringSE queue)
com.rabbitmq.client.AMQP.Queue.UnbindOk
queueUnbind(StringSE queue, StringSE exchange, StringSE routingKey)
com.rabbitmq.client.AMQP.Queue.UnbindOk
queueUnbind(StringSE queue, StringSE exchange, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)
boolean
removeConfirmListener(com.rabbitmq.client.ConfirmListener listener)
boolean
removeReturnListener(com.rabbitmq.client.ReturnListener listener)
void
removeShutdownListener(com.rabbitmq.client.ShutdownListener listener)
com.rabbitmq.client.Command
rpc(com.rabbitmq.client.Method method)
void
setAfterAckCallback(ConsumerSE<com.rabbitmq.client.Channel> callback)
ack/nack が処理された後に呼び出されるコールバックを設定します。void
setDefaultConsumer(com.rabbitmq.client.Consumer consumer)
void
shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause)
StringSE
toString()
com.rabbitmq.client.AMQP.Tx.CommitOk
txCommit()
com.rabbitmq.client.AMQP.Tx.RollbackOk
txRollback()
com.rabbitmq.client.AMQP.Tx.SelectOk
txSelect()
boolean
waitForConfirms()
boolean
waitForConfirms(long timeout)
void
waitForConfirmsOrDie()
void
waitForConfirmsOrDie(long timeout)
コンストラクターの詳細
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
factory
public static PublisherCallbackChannelFactory factory()