クラスの使用
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 操作から一般的にスローされる可能性があるConnectExceptionSE の RuntimeException ラッパー。classIllegalStateException と同等ですが、AmqpException 階層内にあります。classAMQP 操作から一般的にスローできるIOExceptionSE の RuntimeException ラッパー。classDLQ などの機能を有効にするために、basic.rejectがrequeue=falseとともに送信されることを示すために使用されるリスナー実装の例外。classリクエスト / 応答シナリオでサーバーによってスローされた例外をラップする例外。class一部のリソースにアクセスできない場合にスローされるAmqpException。class時間制限のある操作が目的の時間内に実行されなかった場合にスローされる例外。classAMQP 操作でサポートされていないエンコードの RuntimeException。classメッセージの現在のバッチをすぐに確認する必要があることを通知するリスナー実装の特別な例外 (つまりclassリスナーからスローされる特別なAmqpException(例:classAmqpException 階層内で特定の原因が不明な場合の「キャッチオール」例外型。org.springframework.amqp.core 内の AmqpException 使用
修飾子と型クラス説明class必須フラグが設定されているときにリクエストメッセージを配信できない場合にスローされる例外。class非同期応答タイムアウト。AmqpException をスローする org.springframework.amqp.core のメソッド修飾子と型メソッド説明voidAmqpTemplate.convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message) Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用して特定の取引所に送信します。voidAmqpTemplate.convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用して特定の取引所に送信します。voidAmqpTemplate.convertAndSend(@Nullable StringSE routingKey, ObjectSE message) Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。voidAmqpTemplate.convertAndSend(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。voidAmqpTemplate.convertAndSend(ObjectSE message) Java オブジェクトを AmqpMessageに変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。voidAmqpTemplate.convertAndSend(ObjectSE message, MessagePostProcessor messagePostProcessor) Java オブジェクトを AmqpMessageに変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。@Nullable ObjectSEAmqpTemplate.convertSendAndReceive(ObjectSE message) 変換を伴う基本的な RPC パターン。@Nullable ObjectSEAmqpTemplate.convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor) 変換を伴う基本的な RPC パターン。@Nullable ObjectSEAmqpTemplate.convertSendAndReceive(StringSE routingKey, ObjectSE message) 変換を伴う基本的な RPC パターン。@Nullable ObjectSEAmqpTemplate.convertSendAndReceive(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) 変換を伴う基本的な RPC パターン。@Nullable ObjectSEAmqpTemplate.convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE message) 変換を伴う基本的な RPC パターン。@Nullable ObjectSEAmqpTemplate.convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) 変換を伴う基本的な RPC パターン。<T> @Nullable TAmqpTemplate.convertSendAndReceiveAsType(ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> @Nullable TAmqpTemplate.convertSendAndReceiveAsType(ObjectSE message, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> @Nullable TAmqpTemplate.convertSendAndReceiveAsType(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> @Nullable TAmqpTemplate.convertSendAndReceiveAsType(StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> @Nullable TAmqpTemplate.convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> @Nullable TAmqpTemplate.convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。MessagePostProcessor.postProcessMessage(Message message) メッセージを変更 (または置換) します。@Nullable MessageAmqpTemplate.receive()デフォルトキューからのメッセージがある場合は、メッセージを受信します。@Nullable MessageAmqpTemplate.receive(long timeoutMillis) デフォルトのキューからメッセージを受信し、メッセージが利用可能になるまで必要に応じて指定された待機時間まで待機します。@Nullable Message特定のキューからのメッセージがある場合、メッセージを受信します。@Nullable Message特定のキューからメッセージを受信し、メッセージが使用可能になるまで必要に応じて指定された待機時間まで待機します。@Nullable ObjectSEAmqpTemplate.receiveAndConvert()デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。@Nullable ObjectSEAmqpTemplate.receiveAndConvert(long timeoutMillis) デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。<T> @Nullable TAmqpTemplate.receiveAndConvert(long timeoutMillis, ParameterizedTypeReference<T> type) デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。@Nullable ObjectSEAmqpTemplate.receiveAndConvert(StringSE queueName) 特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。@Nullable ObjectSEAmqpTemplate.receiveAndConvert(StringSE queueName, long timeoutMillis) 特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。<T> @Nullable TAmqpTemplate.receiveAndConvert(StringSE queueName, long timeoutMillis, ParameterizedTypeReference<T> type) 特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。<T> @Nullable TAmqpTemplate.receiveAndConvert(StringSE queueName, ParameterizedTypeReference<T> type) 特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。<T> @Nullable TAmqpTemplate.receiveAndConvert(ParameterizedTypeReference<T> type) デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。<R,S> boolean AmqpTemplate.receiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R, S> callback) 指定されたキューからメッセージがある場合はそれを受信し、指定されたReceiveAndReplyCallbackを呼び出して、callbackが応答メッセージを返した場合は、MessagePropertiesからreplyToAddressに、またはデフォルトの交換とデフォルトの routingKey に応答メッセージを送信します。<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の結果からreplyToAddressに送信します。<R,S> boolean AmqpTemplate.receiveAndReply(ReceiveAndReplyCallback<R, S> callback) デフォルトキューからメッセージがある場合はそれを受信し、提供されたReceiveAndReplyCallbackを呼び出して、callbackが応答メッセージを返した場合は、MessagePropertiesからreplyToAddressに、またはデフォルト交換とデフォルト routingKey に応答メッセージを送信します。<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の結果からreplyToAddressに送信します。void特定のルーティングキーを使用して、特定の交換にメッセージを送信します。void特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。voidデフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。@Nullable MessageAmqpTemplate.sendAndReceive(StringSE exchange, StringSE routingKey, Message message) 基本的な RPC パターン。@Nullable MessageAmqpTemplate.sendAndReceive(StringSE routingKey, Message message) 基本的な RPC パターン。@Nullable MessageAmqpTemplate.sendAndReceive(Message message) 基本的な RPC パターン。org.springframework.amqp.rabbit.connection 内の AmqpException 使用
修飾子と型クラス説明classプライマリトランザクションが完了した後に afterCompletion を実行するときにコミットまたはロールバックに失敗したことを示します。class接続が現在開かれておらず、回復中の自動回復接続である場合にスローされる例外。AmqpException をスローする org.springframework.amqp.rabbit.connection のメソッド修飾子と型メソッド説明voidConnection.close()AMQP.REPLY_SUCCESSクローズコードとメッセージ "OK" を使用して、この接続とそのすべてのチャネルを閉じます。voidRabbitResourceHolder.commitAll()com.rabbitmq.client.ChannelConnection.createChannel(boolean transactional) 内部的に割り当てられたチャネル番号を使用して、新しいチャネルを作成します。AbstractRoutingConnectionFactory.createConnection()final ConnectionCachingConnectionFactory.createConnection()ConnectionFactory.createConnection()LocalizedQueueConnectionFactory.createConnection()PooledChannelConnectionFactory.createConnection()ThreadChannelConnectionFactory.createConnection()org.springframework.amqp.rabbit.core 内の AmqpException 使用
修飾子と型クラス説明classメッセージの公開後に否定応答を受信した場合にスローされる例外。classブロッキング受信操作が実行されましたが、受信タイムアウト前に consumeOk が受信されなかった場合にスローされます。AmqpException をスローする org.springframework.amqp.rabbit.core のメソッド修飾子と型メソッド説明voidRabbitOperations.convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用して特定の取引所に送信します。voidRabbitOperations.convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData) Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用して特定の取引所に送信します。voidRabbitOperations.convertAndSend(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。voidRabbitOperations.convertAndSend(@Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData) Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。voidRabbitOperations.convertAndSend(ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) Java オブジェクトを AmqpMessageに変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。voidRabbitTemplate.convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE object) voidRabbitTemplate.convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) voidRabbitTemplate.convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) voidRabbitTemplate.convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE object, @Nullable CorrelationData correlationData) voidRabbitTemplate.convertAndSend(@Nullable StringSE routingKey, ObjectSE object) voidRabbitTemplate.convertAndSend(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) voidRabbitTemplate.convertAndSend(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) voidRabbitTemplate.convertAndSend(@Nullable StringSE routingKey, ObjectSE object, @Nullable CorrelationData correlationData) voidRabbitTemplate.convertAndSend(ObjectSE object) voidRabbitTemplate.convertAndSend(ObjectSE message, MessagePostProcessor messagePostProcessor) voidRabbitTemplate.convertAndSend(ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) @Nullable ObjectSERabbitOperations.convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) 変換を伴う基本的な RPC パターン。@Nullable ObjectSERabbitOperations.convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData) 変換を伴う基本的な RPC パターン。@Nullable ObjectSERabbitOperations.convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) 変換を伴う基本的な RPC パターン。@Nullable ObjectSERabbitOperations.convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData) 変換を伴う基本的な RPC パターン。@Nullable ObjectSERabbitOperations.convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) 変換を伴う基本的な RPC パターン。@Nullable ObjectSERabbitOperations.convertSendAndReceive(ObjectSE message, @Nullable CorrelationData correlationData) 変換を伴う基本的な RPC パターン。@Nullable ObjectSERabbitTemplate.convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(ObjectSE message) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(ObjectSE message, @Nullable CorrelationData correlationData) <T> @Nullable TRabbitOperations.convertSendAndReceiveAsType(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。default <T> @Nullable TRabbitOperations.convertSendAndReceiveAsType(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> @Nullable TRabbitOperations.convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> @Nullable TRabbitOperations.convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> @Nullable TRabbitOperations.convertSendAndReceiveAsType(ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> @Nullable TRabbitOperations.convertSendAndReceiveAsType(ObjectSE message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(ObjectSE message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(ObjectSE message, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) voidRabbitOperations.correlationConvertAndSend(ObjectSE message, CorrelationData correlationData) Java オブジェクトを AmqpMessageに変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。voidRabbitTemplate.correlationConvertAndSend(ObjectSE object, CorrelationData correlationData) <T extends @Nullable ObjectSE>
TRabbitOperations.execute(ChannelCallback<T> action) チャネルを使用してコールバックを実行し、その後チャネルを確実に閉じます。default <T extends @Nullable ObjectSE>
TRabbitOperations.invoke(RabbitOperations.OperationsCallback<T> action) コールバックを呼び出して、専用のスレッドバインドチャネルでテンプレート引数に対するすべての操作を実行し、その後チャネルを確実に閉じます。@Nullable MessageRabbitTemplate.receive()@Nullable MessageRabbitTemplate.receive(long timeoutMillis) @Nullable ObjectSERabbitTemplate.receiveAndConvert()@Nullable ObjectSERabbitTemplate.receiveAndConvert(long timeoutMillis) <T> @Nullable TRabbitTemplate.receiveAndConvert(long timeoutMillis, ParameterizedTypeReference<T> type) @Nullable ObjectSERabbitTemplate.receiveAndConvert(StringSE queueName) @Nullable ObjectSERabbitTemplate.receiveAndConvert(StringSE queueName, long timeoutMillis) <T> @Nullable TRabbitTemplate.receiveAndConvert(StringSE queueName, long timeoutMillis, ParameterizedTypeReference<T> type) <T> @Nullable TRabbitTemplate.receiveAndConvert(StringSE queueName, ParameterizedTypeReference<T> type) <T> @Nullable TRabbitTemplate.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) voidBatchingRabbitTemplate.send(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) voidRabbitOperations.send(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) 特定のルーティングキーを使用して、特定の交換にメッセージを送信します。default voidRabbitOperations.send(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) 特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。voidvoidRabbitTemplate.send(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) voidvoidRabbitTemplate.send(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) void@Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE routingKey, Message message) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) @Nullable MessageRabbitTemplate.sendAndReceive(Message message) @Nullable MessageRabbitTemplate.sendAndReceive(Message message, @Nullable CorrelationData correlationData) booleanRabbitOperations.waitForConfirms(long timeout) 基礎となる専用チャネルに委譲して、confirmsを待機します。voidRabbitOperations.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 のメソッド