インターフェースの使用
org.springframework.amqp.core.MessagePostProcessor
パッケージ
説明
Spring の AMQP 抽象化のためのコアクラスを提供します。
Spring Rabbit のトップレベルクラスを提供します。
Rabbit XML 名前空間をサポートするクラスを提供します。
Spring Rabbit のコアクラスを提供します。
メッセージリスナーコンテナーのクラスを提供します。
リスナーを適応させるためのクラスを提供します。
Spring AMQP メッセージポストプロセッサー用のパッケージ。
ストリームプロデューサーにクラスを提供します。
org.springframework.amqp.core 内の MessagePostProcessor 使用
修飾子と型メソッド説明void
AmqpTemplate.convertAndSend
(ObjectSE message, MessagePostProcessor messagePostProcessor) Java オブジェクトを AmqpMessage
に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。void
AmqpTemplate.convertAndSend
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。void
AmqpTemplate.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用して特定の取引所に送信します。AmqpTemplate.convertSendAndReceive
(ObjectSE message, MessagePostProcessor messagePostProcessor) 変換を伴う基本的な RPC パターン。AmqpTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) 変換を伴う基本的な RPC パターン。AmqpTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) 変換を伴う基本的な RPC パターン。<C> CompletableFutureSE<C>
AsyncAmqpTemplate.convertSendAndReceive
(ObjectSE object, MessagePostProcessor messagePostProcessor) オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。<C> CompletableFutureSE<C>
AsyncAmqpTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor) オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。<C> CompletableFutureSE<C>
AsyncAmqpTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor) MessagePostProcessor
を呼び出した後、オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。<T> T
AmqpTemplate.convertSendAndReceiveAsType
(ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
AmqpTemplate.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<T> T
AmqpTemplate.convertSendAndReceiveAsType
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) 変換を伴う基本的な RPC パターン。<C> CompletableFutureSE<C>
AsyncAmqpTemplate.convertSendAndReceiveAsType
(ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType) オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。<C> CompletableFutureSE<C>
AsyncAmqpTemplate.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType) オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。<C> CompletableFutureSE<C>
AsyncAmqpTemplate.convertSendAndReceiveAsType
(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType) MessagePostProcessor
を呼び出した後、オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。org.springframework.amqp.rabbit 内の MessagePostProcessor 使用
修飾子と型メソッド説明<C> RabbitConverterFuture<C>
AsyncRabbitTemplate.convertSendAndReceive
(ObjectSE object, MessagePostProcessor messagePostProcessor) <C> RabbitConverterFuture<C>
AsyncRabbitTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor) <C> RabbitConverterFuture<C>
AsyncRabbitTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor) <C> RabbitConverterFuture<C>
AsyncRabbitTemplate.convertSendAndReceiveAsType
(ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType) <C> RabbitConverterFuture<C>
AsyncRabbitTemplate.convertSendAndReceiveAsType
(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType) <C> RabbitConverterFuture<C>
AsyncRabbitTemplate.convertSendAndReceiveAsType
(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType) org.springframework.amqp.rabbit.config 内の MessagePostProcessor 使用
修飾子と型メソッド説明void
AbstractRabbitListenerContainerFactory.setAfterReceivePostProcessors
(MessagePostProcessor... postProcessors) メッセージの受信後に適用されるポストプロセッサーを設定します。void
ListenerContainerFactoryBean.setAfterReceivePostProcessors
(MessagePostProcessor... afterReceivePostProcessors) void
BaseRabbitListenerContainerFactory.setBeforeSendReplyPostProcessors
(MessagePostProcessor... postProcessors) 返信を送信する前に適用されるポストプロセッサーを設定します。各メッセージリスナアダプターに追加されます。org.springframework.amqp.rabbit.core 内の MessagePostProcessor 使用
修飾子と型メソッド説明RabbitTemplate.getAfterReceivePostProcessors()
MessagePostProcessor
またはnull
を受信した後に構成を返します。修飾子と型メソッド説明void
RabbitTemplate.addAfterReceivePostProcessors
(MessagePostProcessor... afterReceivePostProcessors) Channel#basicGet()
の直後、メッセージ変換が実行される前に呼び出されるMessagePostProcessor
を追加します。void
RabbitTemplate.addBeforePublishPostProcessors
(MessagePostProcessor... beforePublishPostProcessors) MessageProperties
からAMQP.BasicProperties
を作成する以外のすべての処理の後、Channel#basicPublish()
を呼び出す直前に呼び出されるMessagePostProcessor
を追加します。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 exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Java オブジェクトを AmqpMessage
に変換し、特定のルーティングキーを使用して特定の取引所に送信します。void
RabbitTemplate.convertAndSend
(ObjectSE message, MessagePostProcessor messagePostProcessor) void
RabbitTemplate.convertAndSend
(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) void
RabbitTemplate.convertAndSend
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) void
RabbitTemplate.convertAndSend
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) void
RabbitTemplate.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) void
RabbitTemplate.convertAndSend
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitOperations.convertSendAndReceive
(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) 変換を伴う基本的な RPC パターン。RabbitOperations.convertSendAndReceive
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) 変換を伴う基本的な RPC パターン。RabbitOperations.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) 変換を伴う基本的な RPC パターン。RabbitTemplate.convertSendAndReceive
(ObjectSE message, MessagePostProcessor messagePostProcessor) RabbitTemplate.convertSendAndReceive
(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) RabbitTemplate.convertSendAndReceive
(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) RabbitTemplate.convertSendAndReceive
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) <T> T
RabbitOperations.convertSendAndReceiveAsType
(ObjectSE message, MessagePostProcessor messagePostProcessor, 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 exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, 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
(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 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) protected Message
RabbitTemplate.convertSendAndReceiveRaw
(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) メッセージを変換して送信し、生の返信メッセージまたは null を返します。boolean
RabbitTemplate.removeAfterReceivePostProcessor
(MessagePostProcessor afterReceivePostProcessor) 提供されたMessagePostProcessor
をRabbitTemplate.afterReceivePostProcessors
リストから削除します。boolean
RabbitTemplate.removeBeforePublishPostProcessor
(MessagePostProcessor beforePublishPostProcessor) 提供されたMessagePostProcessor
をRabbitTemplate.beforePublishPostProcessors
リストから削除します。void
RabbitTemplate.setAfterReceivePostProcessors
(MessagePostProcessor... afterReceivePostProcessors) Channel#basicGet()
の直後、メッセージ変換が実行される前に呼び出されるMessagePostProcessor
を設定します。void
RabbitTemplate.setBeforePublishPostProcessors
(MessagePostProcessor... beforePublishPostProcessors) MessageProperties
からAMQP.BasicProperties
を作成する以外のすべての処理の後、Channel#basicPublish()
を呼び出す直前に呼び出されるMessagePostProcessor
を設定します。org.springframework.amqp.rabbit.listener 内の MessagePostProcessor 使用
修飾子と型メソッド説明protected CollectionSE<MessagePostProcessor>
AbstractMessageListenerContainer.getAfterReceivePostProcessors()
修飾子と型メソッド説明void
AbstractMessageListenerContainer.addAfterReceivePostProcessors
(MessagePostProcessor... postprocessors) MessageListener
を呼び出す前に、メッセージの受信後に適用されるMessagePostProcessor
を追加します。boolean
AbstractMessageListenerContainer.removeAfterReceivePostProcessor
(MessagePostProcessor afterReceivePostProcessor) 提供されたMessagePostProcessor
をAbstractMessageListenerContainer.afterReceivePostProcessors
リストから削除します。void
AbstractMessageListenerContainer.setAfterReceivePostProcessors
(MessagePostProcessor... afterReceivePostProcessors) メッセージ受信後、MessageListener
を呼び出す前に適用されるMessagePostProcessor
を設定します。org.springframework.amqp.rabbit.listener.adapter 内の MessagePostProcessor 使用
修飾子と型メソッド説明void
AbstractAdaptableMessageListener.setBeforeSendReplyPostProcessors
(MessagePostProcessor... beforeSendReplyPostProcessors) 返信を送信する前に適用されるポストプロセッサーを設定します。org.springframework.amqp.support.postprocessor 内の MessagePostProcessor 使用
修飾子と型クラス説明class
メッセージ本文を圧縮するポストプロセッサーの基本クラス。class
MessageProperties.SPRING_AUTO_DECOMPRESS
ヘッダーが true の場合にメッセージ本文を解凍する、またはコンテンツエンコーディングがAbstractDecompressingPostProcessor.getEncoding()
と一致する場合、またはAbstractDecompressingPostProcessor.getEncoding()
+ ":" で始まる場合にオプションで常に解凍する、ポストプロセッサーの基本クラス。この場合、コロンに続くエンコーディングが解凍されたメッセージの最終的なコンテンツエンコーディングになります。class
Deflater
SE に基づくポストプロセッサーの基本クラス。class
DeflaterOutputStream
SE を使用してメッセージ本文を圧縮するポストプロセッサー。class
コンテンツのエンコーディングに応じて、そのMessagePostProcessor
の 1 つに委譲するMessagePostProcessor
。class
GZIPInputStream
SE を使用してメッセージ本文を解凍するポストプロセッサー。class
GZIPOutputStream
SE を使用してメッセージ本文を圧縮するポストプロセッサー。class
InflaterInputStream
SE を使用してメッセージ本文を解凍するポストプロセッサー。class
ZipInputStream
SE を使用してメッセージ本文を解凍するポストプロセッサー。class
ZipOutputStream
SE を使用してメッセージ本文を圧縮するポストプロセッサー。修飾子と型メソッド説明DelegatingDecompressingPostProcessor.removeDecompressor
(StringSE contentEncoding) このエンコーディングのデコンプレッサを削除します。MessageProperties.SPRING_AUTO_DECOMPRESS
ヘッダーが true の場合でも、コンテンツは解凍されません。修飾子と型メソッド説明static CollectionSE<MessagePostProcessor>
MessagePostProcessorUtils.sort
(CollectionSE<MessagePostProcessor> processors) 修飾子と型メソッド説明void
DelegatingDecompressingPostProcessor.addDecompressor
(StringSE contentEncoding, MessagePostProcessor decompressor) メッセージポストプロセッサーを解凍 MessageProcessors のマップに追加します。修飾子と型メソッド説明void
DelegatingDecompressingPostProcessor.setDecompressors
(MapSE<StringSE, MessagePostProcessor> decompressors) すべての減圧装置を交換してください。static CollectionSE<MessagePostProcessor>
MessagePostProcessorUtils.sort
(CollectionSE<MessagePostProcessor> processors) org.springframework.rabbit.stream.producer 内の MessagePostProcessor 使用
修飾子と型メソッド説明RabbitStreamOperations.convertAndSend
(ObjectSE message, MessagePostProcessor mpp) Spring AMQP メッセージに変換して送信します。RabbitStreamTemplate.convertAndSend
(ObjectSE message, MessagePostProcessor mpp)