クラスの使用
org.springframework.amqp.rabbit.connection.CorrelationData
CorrelationData を使用するパッケージ
パッケージ
説明
Spring Rabbit のトップレベルクラスを提供します。
接続に関連するクラスを提供します。
Spring Rabbit のコアクラスを提供します。
Spring AMQP アプリケーションをテストするためのクラス。
org.springframework.amqp.rabbit 内の CorrelationData 使用
型 CorrelationData のパラメーターを持つ org.springframework.amqp.rabbit のメソッド修飾子と型メソッド説明voidAsyncRabbitTemplate.confirm(@Nullable CorrelationData correlationData, boolean ack, @Nullable StringSE cause) org.springframework.amqp.rabbit.connection 内の CorrelationData 使用
修飾子と型メソッド説明@Nullable CorrelationDataPendingConfirm.getCorrelationData()この確認に対応するメッセージを送信するときにクライアントによって提供される相関データ。型 CorrelationData のパラメーターを持つ org.springframework.amqp.rabbit.connection のコンストラクターorg.springframework.amqp.rabbit.core 内の CorrelationData 使用
修飾子と型メソッド説明CorrelationDataPostProcessor.postProcess(Message message, @Nullable CorrelationData correlationData) send メソッドで提供される相関データを更新または置換します。型 CorrelationData の引数を持つ型を返す org.springframework.amqp.rabbit.core のメソッド修飾子と型メソッド説明@Nullable CollectionSE<CorrelationData>RabbitTemplate.getUnconfirmed(long age) age よりも古い未確認の相関データを取得して削除します。型 CorrelationData のパラメーターを持つ org.springframework.amqp.rabbit.core のメソッド修飾子と型メソッド説明voidRabbitTemplate.ConfirmCallback.confirm(@Nullable CorrelationData correlationData, boolean ack, @Nullable StringSE cause) 確認のコールバック。voidRabbitOperations.convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData) Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用して特定の取引所に送信します。voidRabbitOperations.convertAndSend(@Nullable StringSE exchange, @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(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @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, @Nullable CorrelationData correlationData) voidRabbitTemplate.convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) voidRabbitTemplate.convertAndSend(@Nullable StringSE routingKey, ObjectSE object, @Nullable CorrelationData correlationData) voidRabbitTemplate.convertAndSend(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) 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, @Nullable CorrelationData correlationData) 変換を伴う基本的な RPC パターン。@Nullable ObjectSERabbitOperations.convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) 変換を伴う基本的な RPC パターン。@Nullable ObjectSERabbitOperations.convertSendAndReceive(ObjectSE message, @Nullable CorrelationData correlationData) 変換を伴う基本的な RPC パターン。@Nullable ObjectSERabbitOperations.convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) 変換を伴う基本的な RPC パターン。@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, @Nullable CorrelationData correlationData) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(ObjectSE message, @Nullable CorrelationData correlationData) @Nullable ObjectSERabbitTemplate.convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor, @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 routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> @Nullable TRabbitTemplate.convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData, 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 CorrelationData correlationData, ParameterizedTypeReference<T> responseType) protected @Nullable MessageRabbitTemplate.convertSendAndReceiveRaw(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) メッセージを変換して送信し、生の返信メッセージまたは null を返します。voidRabbitOperations.correlationConvertAndSend(ObjectSE message, CorrelationData correlationData) Java オブジェクトを AmqpMessageに変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。voidRabbitTemplate.correlationConvertAndSend(ObjectSE object, CorrelationData correlationData) voidRabbitTemplate.doSend(com.rabbitmq.client.Channel channel, @Nullable StringSE exchangeArg, @Nullable StringSE routingKeyArg, Message message, boolean mandatory, @Nullable CorrelationData correlationData) 指定されたメッセージを指定された交換に送信します。protected @Nullable MessageRabbitTemplate.doSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) メッセージを送信し、返信を待ちます。protected @Nullable MessageRabbitTemplate.doSendAndReceiveWithFixed(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) protected @Nullable MessageRabbitTemplate.doSendAndReceiveWithTemporary(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) CorrelationDataPostProcessor.postProcess(Message message, @Nullable CorrelationData correlationData) send メソッドで提供される相関データを更新または置換します。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) 特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。voidRabbitTemplate.send(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) voidRabbitTemplate.send(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) @Nullable MessageRabbitTemplate.sendAndReceive(Message message, @Nullable CorrelationData correlationData) org.springframework.amqp.rabbit.test 内の CorrelationData 使用
型 CorrelationData のパラメーターを持つ org.springframework.amqp.rabbit.test のメソッド修飾子と型メソッド説明protected @Nullable MessageTestRabbitTemplate.doSendAndReceiveWithFixed(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData)