パッケージ org.springframework.amqp.support.postprocessor

クラス DelegatingDecompressingPostProcessor

java.lang.ObjectSE
org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
実装されたすべてのインターフェース:
MessagePostProcessor, Ordered
public class DelegatingDecompressingPostProcessor extends ObjectSE implements MessagePostProcessor, Ordered
コンテンツのエンコーディングに応じて、その MessagePostProcessor の 1 つに委譲する MessagePostProcessor。デフォルトで gzip, zip, deflate をサポートします。
導入:
1.4.2
作成者:
Gary Russell, David Diehl

  • コンストラクターの詳細

    • DelegatingDecompressingPostProcessor

      public DelegatingDecompressingPostProcessor()
      alwaysDecompress フラグを true に設定して、デフォルトの圧縮解除プログラム (gzip、zip、deflate) でインスタンスを構築します。

  • メソッドの詳細

    • getOrder

      public int getOrder()
      次で指定:
      インターフェース Ordered の getOrder 

    • setOrder

      public void setOrder(int order)
      順序を設定します。
      パラメーター:
      order - オーダー。
      関連事項:

    • addDecompressor

      public void addDecompressor(StringSE contentEncoding, MessagePostProcessor decompressor)
      メッセージポストプロセッサーを解凍 MessageProcessors のマップに追加します。
      パラメーター:
      contentEncoding - コンテンツのエンコーディング ; content-encoding プロパティが一致するか、このキーで始まり、その後に ":" が続く場合、メッセージはこのポストプロセッサーで解凍されます。
      decompressor - 解凍 MessagePostProcessor。

    • removeDecompressor

      public MessagePostProcessor removeDecompressor(StringSE contentEncoding)
      このエンコーディングのデコンプレッサを削除します。MessageProperties.SPRING_AUTO_DECOMPRESS ヘッダーが true の場合でも、コンテンツは解凍されません。
      パラメーター:
      contentEncoding - コンテンツのエンコーディング。
      戻り値:
      存在する場合は解凍器。

    • setDecompressors

      public void setDecompressors(MapSE<StringSE,MessagePostProcessor> decompressors)
      すべての減圧装置を交換してください。
      パラメーター:
      decompressors - デコンプレッサ。

    • postProcessMessage

      public Message postProcessMessage(Message message) throws AmqpException
      インターフェースからコピーされた説明: MessagePostProcessor
      メッセージを変更 (または置換) します。
      次で指定:
      インターフェース MessagePostProcessor の postProcessMessage 
      パラメーター:
      message - メッセージ。
      戻り値:
      メッセージ。
      例外:
      AmqpException - 例外。