クラスの使用
org.springframework.amqp.AmqpException
AmqpException を使用するパッケージ
パッケージ
説明
Spring AMQP の基本パッケージ。
Spring の AMQP 抽象化のためのコアクラスを提供します。
接続に関連するクラスを提供します。
Spring Rabbit のコアクラスを提供します。
メッセージリスナーコンテナーのクラスを提供します。
リスナーを適応させるためのクラスを提供します。
リスナー例外のクラスを提供します。
Spring Rabbit のサポートクラスを提供します。
メッセージ変換をサポートするためのクラスを提供します。
Spring AMQP メッセージポストプロセッサー用のパッケージ。
ストリームプロデューサーにクラスを提供します。
org.springframework.amqp 内の AmqpException 使用
org.springframework.amqp 内の AmqpException サブクラス修飾子と型クラス説明class
コンテキストのクローズ中に接続ファクトリが破棄された場合にスローされます。ファクトリは接続を開くことができなくなります。class
認証例外のランタイムラッパー。class
リモートプロセスが終了した場合、またはネットワークの課題がある場合に、AMQP 操作から一般的にスローされる可能性があるConnectException
SE の RuntimeException ラッパー。class
IllegalStateException と同等ですが、AmqpException 階層内にあります。class
AMQP 操作から一般的にスローできるIOException
SE の RuntimeException ラッパー。class
DLQ などの機能を有効にするために、basic.reject が requeue=false で送信されることを示すために使用されるリスナー実装の例外。class
リクエスト / 応答シナリオでサーバーによってスローされた例外をラップする例外。class
一部のリソースにアクセスできない場合にスローされるAmqpException
。class
時間制限のある操作が目的の時間内に実行されなかった場合にスローされる例外。class
AMQP 操作でサポートされていないエンコードの RuntimeException。class
メッセージの現在のバッチをすぐに確認する必要があることを通知するリスナー実装の特別な例外 (つまりclass
リスナーからスローされる特別なAmqpException
(例:class
AmqpException 階層内で特定の原因が不明な場合の「キャッチオール」例外型。org.springframework.amqp.core 内の AmqpException 使用
修飾子と型クラス説明class
必須フラグが設定されているときにリクエストメッセージを配信できない場合にスローされる例外。class
非同期応答タイムアウト。AmqpException をスローする org.springframework.amqp.core のメソッド修飾子と型メソッド説明void
AmqpTemplate.convertAndSend
(ObjectSE message) Java オブジェクトを AmqpMessage
に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。void
AmqpTemplate.convertAndSend
(ObjectSE message, MessagePostProcessor messagePostProcessor) Java オブジェクトを AmqpMessage
に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。void
AmqpTemplate.convertAndSend
(StringSE routingKey, ObjectSE message) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。void
AmqpTemplate.convertAndSend
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。void
AmqpTemplate.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE message) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用して特定の取引所に送信します。void
AmqpTemplate.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用して特定の取引所に送信します。AmqpTemplate.convertSendAndReceive
(ObjectSE message) 変換を伴う基本的な RPC パターン。AmqpTemplate.convertSendAndReceive
(ObjectSE message, MessagePostProcessor messagePostProcessor) 変換を伴う基本的な RPC パターン。AmqpTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE message) 変換を伴う基本的な RPC パターン。AmqpTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) 変換を伴う基本的な RPC パターン。AmqpTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message) 変換を伴う基本的な RPC パターン。AmqpTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) 変換を伴う基本的な RPC パターン。<T> T
AmqpTemplate.convertSendAndReceiveAsType
(ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
AmqpTemplate.convertSendAndReceiveAsType
(ObjectSE message, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
AmqpTemplate.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
AmqpTemplate.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
AmqpTemplate.convertSendAndReceiveAsType
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
AmqpTemplate.convertSendAndReceiveAsType
(StringSE exchange, StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。MessagePostProcessor.postProcessMessage
(Message message) メッセージを変更 (または置換) します。AmqpTemplate.receive()
デフォルトキューからのメッセージがある場合は、メッセージを受信します。AmqpTemplate.receive
(long timeoutMillis) デフォルトのキューからメッセージを受信し、メッセージが利用可能になるまで必要に応じて指定された待機時間まで待機します。特定のキューからのメッセージがある場合、メッセージを受信します。特定のキューからメッセージを受信し、メッセージが使用可能になるまで必要に応じて指定された待機時間まで待機します。AmqpTemplate.receiveAndConvert()
デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。AmqpTemplate.receiveAndConvert
(long timeoutMillis) デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。<T> T
AmqpTemplate.receiveAndConvert
(long timeoutMillis, ParameterizedTypeReference<T> type) デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。AmqpTemplate.receiveAndConvert
(StringSE queueName) 特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。AmqpTemplate.receiveAndConvert
(StringSE queueName, long timeoutMillis) 特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。<T> T
AmqpTemplate.receiveAndConvert
(StringSE queueName, long timeoutMillis, ParameterizedTypeReference<T> type) 特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。<T> T
AmqpTemplate.receiveAndConvert
(StringSE queueName, ParameterizedTypeReference<T> type) 特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。<T> T
AmqpTemplate.receiveAndConvert
(ParameterizedTypeReference<T> type) デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。<R,
S> boolean AmqpTemplate.receiveAndReply
(StringSE queueName, ReceiveAndReplyCallback<R, S> callback) 提供されたキューからメッセージがある場合はメッセージを受信し、提供されたReceiveAndReplyCallback
を呼び出し、応答メッセージを送信します。callback
がメッセージを返す場合は、MessageProperties
からreplyTo
Address
に、またはデフォルト交換とデフォルトルーティングキーに送信します。<R,
S> boolean AmqpTemplate.receiveAndReply
(StringSE queueName, ReceiveAndReplyCallback<R, S> callback, StringSE replyExchange, StringSE replyRoutingKey) 提供されたキューからメッセージがある場合はメッセージを受信し、提供されたReceiveAndReplyCallback
を呼び出し、callback
がメッセージを返す場合は、提供されたexchange
およびroutingKey
に応答メッセージを送信します。<R,
S> boolean AmqpTemplate.receiveAndReply
(StringSE queueName, ReceiveAndReplyCallback<R, S> callback, ReplyToAddressCallback<S> replyToAddressCallback) 指定されたキューからメッセージがあれば受信し、指定されたReceiveAndReplyCallback
を呼び出し、callback
がメッセージを返す場合は、応答メッセージをReplyToAddressCallback
の結果からreplyTo
Address
に送信します。<R,
S> boolean AmqpTemplate.receiveAndReply
(ReceiveAndReplyCallback<R, S> callback) デフォルトキューからメッセージがあれば受信し、提供されたReceiveAndReplyCallback
を呼び出し、callback
がメッセージを返す場合は、応答メッセージをMessageProperties
からreplyTo
Address
に、またはデフォルト交換とデフォルトルーティングキーに送信します。<R,
S> boolean AmqpTemplate.receiveAndReply
(ReceiveAndReplyCallback<R, S> callback, StringSE replyExchange, StringSE replyRoutingKey) デフォルトキューからメッセージがある場合はメッセージを受信し、提供されたReceiveAndReplyCallback
を呼び出し、callback
がメッセージを返す場合は、提供されたexchange
およびroutingKey
に応答メッセージを送信します。<R,
S> boolean AmqpTemplate.receiveAndReply
(ReceiveAndReplyCallback<R, S> callback, ReplyToAddressCallback<S> replyToAddressCallback) デフォルトのキューからメッセージがあれば受信し、提供されたReceiveAndReplyCallback
を呼び出し、callback
がメッセージを返す場合は、応答メッセージをReplyToAddressCallback
の結果からreplyTo
Address
に送信します。void
特定のルーティングキーを使用して、特定の交換にメッセージを送信します。void
特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。void
デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。AmqpTemplate.sendAndReceive
(StringSE exchange, StringSE routingKey, Message message) 基本的な RPC パターン。AmqpTemplate.sendAndReceive
(StringSE routingKey, Message message) 基本的な RPC パターン。AmqpTemplate.sendAndReceive
(Message message) 基本的な RPC パターン。org.springframework.amqp.rabbit.connection 内の AmqpException 使用
修飾子と型クラス説明class
プライマリトランザクションの補完後に afterCompletion を実行すると、コミットまたはロールバックに失敗したことを表します。class
接続が現在開かれておらず、回復中の自動回復接続である場合にスローされる例外。AmqpException をスローする org.springframework.amqp.rabbit.connection のメソッド修飾子と型メソッド説明void
Connection.close()
AMQP.REPLY_SUCCESS
クローズコードとメッセージ "OK" を使用して、この接続とそのすべてのチャネルを閉じます。void
RabbitResourceHolder.commitAll()
com.rabbitmq.client.Channel
Connection.createChannel
(boolean transactional) 内部的に割り当てられたチャネル番号を使用して、新しいチャネルを作成します。AbstractRoutingConnectionFactory.createConnection()
final Connection
CachingConnectionFactory.createConnection()
ConnectionFactory.createConnection()
LocalizedQueueConnectionFactory.createConnection()
PooledChannelConnectionFactory.createConnection()
ThreadChannelConnectionFactory.createConnection()
org.springframework.amqp.rabbit.core 内の AmqpException 使用
修飾子と型クラス説明class
メッセージの公開後に否定応答を受信した場合にスローされる例外。class
ブロッキング受信操作が実行されましたが、受信タイムアウトの前に consumerOk が受信されなかった場合にスローされます。AmqpException をスローする org.springframework.amqp.rabbit.core のメソッド修飾子と型メソッド説明void
RabbitOperations.convertAndSend
(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Java オブジェクトを AmqpMessage
に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。void
RabbitOperations.convertAndSend
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。void
RabbitOperations.convertAndSend
(StringSE routingKey, ObjectSE message, CorrelationData correlationData) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。void
RabbitOperations.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用して特定の取引所に送信します。void
RabbitOperations.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE message, CorrelationData correlationData) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用して特定の取引所に送信します。void
RabbitTemplate.convertAndSend
(ObjectSE object) void
RabbitTemplate.convertAndSend
(ObjectSE message, MessagePostProcessor messagePostProcessor) void
RabbitTemplate.convertAndSend
(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) void
RabbitTemplate.convertAndSend
(StringSE routingKey, ObjectSE object) void
RabbitTemplate.convertAndSend
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) void
RabbitTemplate.convertAndSend
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) void
RabbitTemplate.convertAndSend
(StringSE routingKey, ObjectSE object, CorrelationData correlationData) void
RabbitTemplate.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE object) void
RabbitTemplate.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) void
RabbitTemplate.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) void
RabbitTemplate.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE object, CorrelationData correlationData) RabbitOperations.convertSendAndReceive
(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) 変換を伴う基本的な RPC パターン。RabbitOperations.convertSendAndReceive
(ObjectSE message, CorrelationData correlationData) 変換を伴う基本的な RPC パターン。RabbitOperations.convertSendAndReceive
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) 変換を伴う基本的な RPC パターン。RabbitOperations.convertSendAndReceive
(StringSE routingKey, ObjectSE message, CorrelationData correlationData) 変換を伴う基本的な RPC パターン。RabbitOperations.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) 変換を伴う基本的な RPC パターン。RabbitOperations.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message, CorrelationData correlationData) 変換を伴う基本的な RPC パターン。RabbitTemplate.convertSendAndReceive
(ObjectSE message) RabbitTemplate.convertSendAndReceive
(ObjectSE message, MessagePostProcessor messagePostProcessor) RabbitTemplate.convertSendAndReceive
(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(ObjectSE message, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE message) RabbitTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) RabbitTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE message, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message) RabbitTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) RabbitTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message, CorrelationData correlationData) <T> T
RabbitOperations.convertSendAndReceiveAsType
(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
RabbitOperations.convertSendAndReceiveAsType
(ObjectSE message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
RabbitOperations.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
RabbitOperations.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
RabbitOperations.convertSendAndReceiveAsType
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。default <T> T
RabbitOperations.convertSendAndReceiveAsType
(StringSE exchange, StringSE routingKey, ObjectSE message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
RabbitTemplate.convertSendAndReceiveAsType
(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(ObjectSE message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(ObjectSE message, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(StringSE exchange, StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) void
RabbitOperations.correlationConvertAndSend
(ObjectSE message, CorrelationData correlationData) Java オブジェクトを AmqpMessage
に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。void
RabbitTemplate.correlationConvertAndSend
(ObjectSE object, CorrelationData correlationData) <T> T
RabbitOperations.execute
(ChannelCallback<T> action) チャネルでコールバックを実行し、その後チャネルを確実に閉じます。default <T> T
RabbitOperations.invoke
(RabbitOperations.OperationsCallback<T> action) コールバックを呼び出し、専用のスレッドバインドチャネルでテンプレート引数に対してすべての操作を実行し、後で確実にチャネルを閉じます。RabbitTemplate.receive()
RabbitTemplate.receive
(long timeoutMillis) RabbitTemplate.receiveAndConvert()
RabbitTemplate.receiveAndConvert
(long timeoutMillis) <T> T
RabbitTemplate.receiveAndConvert
(long timeoutMillis, ParameterizedTypeReference<T> type) RabbitTemplate.receiveAndConvert
(StringSE queueName) RabbitTemplate.receiveAndConvert
(StringSE queueName, long timeoutMillis) <T> T
RabbitTemplate.receiveAndConvert
(StringSE queueName, long timeoutMillis, ParameterizedTypeReference<T> type) <T> T
RabbitTemplate.receiveAndConvert
(StringSE queueName, ParameterizedTypeReference<T> type) <T> T
RabbitTemplate.receiveAndConvert
(ParameterizedTypeReference<T> type) <R,
S> boolean RabbitTemplate.receiveAndReply
(StringSE queueName, ReceiveAndReplyCallback<R, S> callback) <R,
S> boolean RabbitTemplate.receiveAndReply
(StringSE queueName, ReceiveAndReplyCallback<R, S> callback, StringSE replyExchange, StringSE replyRoutingKey) <R,
S> boolean RabbitTemplate.receiveAndReply
(StringSE queueName, ReceiveAndReplyCallback<R, S> callback, ReplyToAddressCallback<S> replyToAddressCallback) <R,
S> boolean RabbitTemplate.receiveAndReply
(ReceiveAndReplyCallback<R, S> callback) <R,
S> boolean RabbitTemplate.receiveAndReply
(ReceiveAndReplyCallback<R, S> callback, StringSE exchange, StringSE routingKey) <R,
S> boolean RabbitTemplate.receiveAndReply
(ReceiveAndReplyCallback<R, S> callback, ReplyToAddressCallback<S> replyToAddressCallback) void
BatchingRabbitTemplate.send
(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) void
RabbitOperations.send
(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) 特定のルーティングキーを使用して、特定の交換にメッセージを送信します。default void
RabbitOperations.send
(StringSE routingKey, Message message, CorrelationData correlationData) 特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。void
void
RabbitTemplate.send
(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) void
void
RabbitTemplate.send
(StringSE routingKey, Message message, CorrelationData correlationData) void
RabbitTemplate.sendAndReceive
(StringSE exchange, StringSE routingKey, Message message) RabbitTemplate.sendAndReceive
(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive
(StringSE routingKey, Message message) RabbitTemplate.sendAndReceive
(StringSE routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive
(Message message) RabbitTemplate.sendAndReceive
(Message message, CorrelationData correlationData) boolean
RabbitOperations.waitForConfirms
(long timeout) 基礎となる専用チャネルに委譲して、確認を待ちます。void
RabbitOperations.waitForConfirmsOrDie
(long timeout) 基礎となる専用チャネルに委譲して、確認を待ちます。org.springframework.amqp.rabbit.listener 内の AmqpException 使用
AmqpException をスローする org.springframework.amqp.rabbit.listener のメソッドorg.springframework.amqp.rabbit.listener.adapter 内の AmqpException 使用
org.springframework.amqp.rabbit.listener.exception 内の AmqpException 使用
修飾子と型クラス説明class
リスナーメソッドの実行が回復不能な問題で失敗した場合にスローされる例外。class
起動時にリスナーメソッドの実行が失敗した場合にスローされる例外。class
シャットダウン時に拒否されたメッセージを示す例外クラス。org.springframework.amqp.rabbit.support 内の AmqpException 使用
org.springframework.amqp.support.converter 内の AmqpException 使用
org.springframework.amqp.support.postprocessor 内の AmqpException 使用
修飾子と型メソッド説明AbstractCompressingPostProcessor.postProcessMessage
(Message message) AbstractDecompressingPostProcessor.postProcessMessage
(Message message) DelegatingDecompressingPostProcessor.postProcessMessage
(Message message) org.springframework.rabbit.stream.producer 内の AmqpException 使用
AmqpException をスローする org.springframework.rabbit.stream.producer のメソッド