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