パッケージ org.springframework.amqp.core

インターフェース MessagePostProcessor

すべての既知の実装クラス:
AbstractCompressingPostProcessor、AbstractDecompressingPostProcessor、AbstractDeflaterPostProcessor、DeflaterPostProcessor、DelegatingDecompressingPostProcessor、GUnzipPostProcessor、GZipPostProcessor、InflaterPostProcessor、UnzipPostProcessor、ZipPostProcessor
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public interface MessagePostProcessor
メッセージ変換が実行された後にヘッダーまたはプロパティを追加 / 変更するために使用できる AmqpTemplate#convertAndSend(Object, MessagePostProcessor) など、フレームワークのいくつかの場所で使用されます。また、リスナーコンテナーおよび AmqpTemplate でメッセージを受信するときに、受信メッセージを変更するためにも使用できます。

これは FunctionalInterfaceSE であり、ラムダとしてよく使用されます。

 amqpTemplate.convertAndSend(routingKey, m -> {
     m.getMessageProperties().setDeliveryMode(DeliveryMode.NON_PERSISTENT);
     return m;
 });
作成者:
Mark Pollack, Gary Russell

  • 方法の詳細

    • postProcessMessage

      Message postProcessMessage(Message message) throws AmqpException
      メッセージを変更 (または置換) します。
      パラメーター:
      message - メッセージ。
      戻り値:
      メッセージ。
      例外:
      AmqpException - 例外。

    • postProcessMessage

      default Message postProcessMessage(Message message, @Nullable Correlation correlation)
      メッセージを変更 (または置換) し、その相関データを変更します。送信メッセージにのみ適用されます。
      パラメーター:
      message - メッセージ。
      correlation - 相関データ。
      戻り値:
      メッセージ。
      導入:
      1.6.7

    • postProcessMessage

      default Message postProcessMessage(Message message, @Nullable Correlation correlation, StringSE exchange, StringSE routingKey)
      メッセージを変更 (または置換) し、その相関データを変更します。送信メッセージにのみ適用されます。
      パラメーター:
      message - メッセージ。
      correlation - 相関データ。
      exchange - メッセージの送信先の交換。
      routingKey - ルーティングキー。
      戻り値:
      メッセージ。
      導入:
      2.3.4