クラス 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インスタンスを作成します。
方法の概要
すべてのメソッド 静的メソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 voidabort()voidabort(int closeCode, StringSE closeMessage)com.rabbitmq.client.ConfirmListeneraddConfirmListener(com.rabbitmq.client.ConfirmCallback ackCallback, com.rabbitmq.client.ConfirmCallback nackCallback)voidaddConfirmListener(com.rabbitmq.client.ConfirmListener listener)voidaddListener(PublisherCallbackChannel.Listener listener)リスナーを追加し、そのリスナーの保留中の確認の内部マップを返します。voidaddPendingConfirm(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm)保留中の確認をこのチャネルのマップに追加します。com.rabbitmq.client.ReturnListeneraddReturnListener(com.rabbitmq.client.ReturnCallback returnCallback)5.0.x クライアントに追加されました。voidaddReturnListener(com.rabbitmq.client.ReturnListener listener)voidaddShutdownListener(com.rabbitmq.client.ShutdownListener listener)CompletableFutureSE<com.rabbitmq.client.Command>asyncCompletableRpc(com.rabbitmq.client.Method method)5.0.x クライアントに追加されました。voidasyncRpc(com.rabbitmq.client.Method method)voidbasicAck(long deliveryTag, boolean multiple)voidbasicCancel(StringSE consumerTag)StringSEbasicConsume(StringSE queue, boolean autoAck, com.rabbitmq.client.Consumer callback)StringSEbasicConsume(StringSE queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)5.0.x クライアントに追加されました。StringSEbasicConsume(StringSE queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)5.0.x クライアントに追加されました。StringSEbasicConsume(StringSE queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)5.0.x クライアントに追加されました。StringSEbasicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, boolean noLocal, boolean exclusive, MapSE<StringSE,ObjectSE> arguments, com.rabbitmq.client.Consumer callback)StringSEbasicConsume(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 クライアントに追加されました。StringSEbasicConsume(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 クライアントに追加されました。StringSEbasicConsume(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 クライアントに追加されました。StringSEbasicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, com.rabbitmq.client.Consumer callback)StringSEbasicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)5.0.x クライアントに追加されました。StringSEbasicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)5.0.x クライアントに追加されました。StringSEbasicConsume(StringSE queue, boolean autoAck, StringSE consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)5.0.x クライアントに追加されました。StringSEbasicConsume(StringSE queue, boolean autoAck, MapSE<StringSE,ObjectSE> arguments, com.rabbitmq.client.Consumer callback)3.3.x クライアントに追加されました。StringSEbasicConsume(StringSE queue, boolean autoAck, MapSE<StringSE,ObjectSE> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)5.0.x クライアントに追加されました。StringSEbasicConsume(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 クライアントに追加されました。StringSEbasicConsume(StringSE queue, boolean autoAck, MapSE<StringSE,ObjectSE> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)5.0.x クライアントに追加されました。StringSEbasicConsume(StringSE queue, com.rabbitmq.client.Consumer callback)StringSEbasicConsume(StringSE queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)5.0.x クライアントに追加されました。StringSEbasicConsume(StringSE queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)5.0.x クライアントに追加されました。StringSEbasicConsume(StringSE queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)5.0.x クライアントに追加されました。com.rabbitmq.client.GetResponsebasicGet(StringSE queue, boolean autoAck)voidbasicNack(long deliveryTag, boolean multiple, boolean requeue)voidbasicPublish(StringSE exchange, StringSE routingKey, boolean mandatory, boolean immediate, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body)voidbasicPublish(StringSE exchange, StringSE routingKey, boolean mandatory, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body)voidbasicPublish(StringSE exchange, StringSE routingKey, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body)voidbasicQos(int prefetchCount)voidbasicQos(int prefetchCount, boolean global)3.3.x クライアントに追加されました。voidbasicQos(int prefetchSize, int prefetchCount, boolean global)com.rabbitmq.client.AMQP.Basic.RecoverOkbasicRecover()com.rabbitmq.client.AMQP.Basic.RecoverOkbasicRecover(boolean requeue)voidbasicReject(long deliveryTag, boolean requeue)voidclearConfirmListeners()voidclearReturnListeners()voidclose()voidclose(int closeCode, StringSE closeMessage)com.rabbitmq.client.AMQP.Confirm.SelectOkconfirmSelect()longconsumerCount(StringSE queue)booleanequals(ObjectSE obj)com.rabbitmq.client.AMQP.Exchange.BindOkexchangeBind(StringSE destination, StringSE source, StringSE routingKey)com.rabbitmq.client.AMQP.Exchange.BindOkexchangeBind(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)voidexchangeBindNoWait(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)com.rabbitmq.client.AMQP.Exchange.DeclareOkexchangeDeclare(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type)com.rabbitmq.client.AMQP.Exchange.DeclareOkexchangeDeclare(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable)com.rabbitmq.client.AMQP.Exchange.DeclareOkexchangeDeclare(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, MapSE<StringSE,ObjectSE> arguments)com.rabbitmq.client.AMQP.Exchange.DeclareOkexchangeDeclare(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, MapSE<StringSE,ObjectSE> arguments)com.rabbitmq.client.AMQP.Exchange.DeclareOkexchangeDeclare(StringSE exchange, StringSE type)com.rabbitmq.client.AMQP.Exchange.DeclareOkexchangeDeclare(StringSE exchange, StringSE type, boolean durable)com.rabbitmq.client.AMQP.Exchange.DeclareOkexchangeDeclare(StringSE exchange, StringSE type, boolean durable, boolean autoDelete, boolean internal, MapSE<StringSE,ObjectSE> arguments)com.rabbitmq.client.AMQP.Exchange.DeclareOkexchangeDeclare(StringSE exchange, StringSE type, boolean durable, boolean autoDelete, MapSE<StringSE,ObjectSE> arguments)voidexchangeDeclareNoWait(StringSE exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, MapSE<StringSE,ObjectSE> arguments)voidexchangeDeclareNoWait(StringSE exchange, StringSE type, boolean durable, boolean autoDelete, boolean internal, MapSE<StringSE,ObjectSE> arguments)com.rabbitmq.client.AMQP.Exchange.DeclareOkexchangeDeclarePassive(StringSE name)com.rabbitmq.client.AMQP.Exchange.DeleteOkexchangeDelete(StringSE exchange)com.rabbitmq.client.AMQP.Exchange.DeleteOkexchangeDelete(StringSE exchange, boolean ifUnused)voidexchangeDeleteNoWait(StringSE exchange, boolean ifUnused)com.rabbitmq.client.AMQP.Exchange.UnbindOkexchangeUnbind(StringSE destination, StringSE source, StringSE routingKey)com.rabbitmq.client.AMQP.Exchange.UnbindOkexchangeUnbind(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)voidexchangeUnbindNoWait(StringSE destination, StringSE source, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)CollectionSE<PendingConfirm>expire(PublisherCallbackChannel.Listener listener, long cutoffTime)指定されたリスナーの cutoffTime より前に作成されたPendingConfirmをすべて期限切れ (削除) にして、呼び出し元に返します。static PublisherCallbackChannelFactoryfactory()intgetChannelNumber()com.rabbitmq.client.ShutdownSignalExceptiongetCloseReason()com.rabbitmq.client.ConnectiongetConnection()com.rabbitmq.client.ConsumergetDefaultConsumer()com.rabbitmq.client.ChannelgetDelegate()これを使用して、この実装ではサポートされていない、基礎となる rabbit クライアントChannelのメソッドを呼び出します。longgetNextPublishSeqNo()intgetPendingConfirmsCount()保留中の合計確認数を取得します。intgetPendingConfirmsCount(PublisherCallbackChannel.Listener listener)PendingConfirmのカウントを取得します。voidhandle(com.rabbitmq.client.Return returned)voidhandleAck(long seq, boolean multiple)voidhandleNack(long seq, boolean multiple)inthashCode()booleanisOpen()longmessageCount(StringSE queue)voidnotifyListeners()com.rabbitmq.client.AMQP.Queue.BindOkqueueBind(StringSE queue, StringSE exchange, StringSE routingKey)com.rabbitmq.client.AMQP.Queue.BindOkqueueBind(StringSE queue, StringSE exchange, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)voidqueueBindNoWait(StringSE queue, StringSE exchange, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)com.rabbitmq.client.AMQP.Queue.DeclareOkqueueDeclare()com.rabbitmq.client.AMQP.Queue.DeclareOkqueueDeclare(StringSE queue, boolean durable, boolean exclusive, boolean autoDelete, MapSE<StringSE,ObjectSE> arguments)voidqueueDeclareNoWait(StringSE queue, boolean durable, boolean exclusive, boolean autoDelete, MapSE<StringSE,ObjectSE> arguments)com.rabbitmq.client.AMQP.Queue.DeclareOkqueueDeclarePassive(StringSE queue)com.rabbitmq.client.AMQP.Queue.DeleteOkqueueDelete(StringSE queue)com.rabbitmq.client.AMQP.Queue.DeleteOkqueueDelete(StringSE queue, boolean ifUnused, boolean ifEmpty)voidqueueDeleteNoWait(StringSE queue, boolean ifUnused, boolean ifEmpty)com.rabbitmq.client.AMQP.Queue.PurgeOkqueuePurge(StringSE queue)com.rabbitmq.client.AMQP.Queue.UnbindOkqueueUnbind(StringSE queue, StringSE exchange, StringSE routingKey)com.rabbitmq.client.AMQP.Queue.UnbindOkqueueUnbind(StringSE queue, StringSE exchange, StringSE routingKey, MapSE<StringSE,ObjectSE> arguments)booleanremoveConfirmListener(com.rabbitmq.client.ConfirmListener listener)booleanremoveReturnListener(com.rabbitmq.client.ReturnListener listener)voidremoveShutdownListener(com.rabbitmq.client.ShutdownListener listener)com.rabbitmq.client.Commandrpc(com.rabbitmq.client.Method method)voidsetAfterAckCallback(ConsumerSE<com.rabbitmq.client.Channel> callback)ack/nack が処理された後に呼び出されるコールバックを設定します。voidsetDefaultConsumer(com.rabbitmq.client.Consumer consumer)voidshutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause)StringSEtoString()com.rabbitmq.client.AMQP.Tx.CommitOktxCommit()com.rabbitmq.client.AMQP.Tx.RollbackOktxRollback()com.rabbitmq.client.AMQP.Tx.SelectOktxSelect()booleanwaitForConfirms()booleanwaitForConfirms(long timeout)voidwaitForConfirmsOrDie()voidwaitForConfirmsOrDie(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)
インターフェースからコピーされた説明:PublisherCallbackChannelack/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 - 例外:
IOExceptionSETimeoutExceptionSE
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 IOExceptionSE3.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 - 例外:
InterruptedExceptionSETimeoutExceptionSE
waitForConfirmsOrDie
public void waitForConfirmsOrDie() throws IOExceptionSE, InterruptedExceptionSE- 次で指定:
- インターフェース
com.rabbitmq.client.Channel内のwaitForConfirmsOrDie - 例外:
IOExceptionSEInterruptedExceptionSE
waitForConfirmsOrDie
public void waitForConfirmsOrDie(long timeout) throws IOExceptionSE, InterruptedExceptionSE, TimeoutExceptionSE- 次で指定:
- インターフェース
com.rabbitmq.client.Channel内のwaitForConfirmsOrDie - 例外:
IOExceptionSEInterruptedExceptionSETimeoutExceptionSE
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 - 例外:
IOExceptionSETimeoutExceptionSE
getPendingConfirmsCount
public int getPendingConfirmsCount(PublisherCallbackChannel.Listener listener)
インターフェースからコピーされた説明:PublisherCallbackChannelPendingConfirmのカウントを取得します。- 次で指定:
- インターフェース
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()