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

クラス AbstractDecompressingPostProcessor

java.lang.ObjectSE
org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
実装済みのインターフェース一覧:
MessagePostProcessor, Ordered
既知の直属サブクラス
GUnzipPostProcessor、InflaterPostProcessor、UnzipPostProcessor
public abstract class AbstractDecompressingPostProcessor extends ObjectSE implements MessagePostProcessor, Ordered
MessageProperties.SPRING_AUTO_DECOMPRESS ヘッダーが true の場合にメッセージ本文を解凍する、またはコンテンツエンコーディングが getEncoding() と一致する場合、または getEncoding() + ":" で始まる場合にオプションで常に解凍する、ポストプロセッサーの基本クラス。この場合、コロンに続くエンコーディングが解凍されたメッセージの最終的なコンテンツエンコーディングになります。
導入:
1.4.2
作成者:
Gary Russell, Ngoc Nhan, Artem Bilan

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

    • AbstractDecompressingPostProcessor

      public AbstractDecompressingPostProcessor()
      MessageProperties.SPRING_AUTO_DECOMPRESS ヘッダーが存在し、true の場合にのみ、サポートされているコンテンツエンコーディングを解凍するポストプロセッサーを構築します。

    • AbstractDecompressingPostProcessor

      public AbstractDecompressingPostProcessor(boolean alwaysDecompress)
      MessageProperties.SPRING_AUTO_DECOMPRESS ヘッダーが存在し、それが true の場合、または alwaysDecompress が true の場合、サポートされているコンテンツエンコーディングを解凍するポストプロセッサーを構築します。
      パラメーター:
      alwaysDecompress - 常に解凍する場合は true。

  • 方法の詳細

    • getOrder

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

    • setOrder

      protected void setOrder(int order)
      順序を設定します。
      パラメーター:
      order - 順序、デフォルトは 0。
      関連事項:

    • postProcessMessage

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

    • getDecompressorStream

      protected abstract InputStreamSE getDecompressorStream(InputStreamSE stream) throws IOExceptionSE
      ストリームを取得します。
      パラメーター:
      stream - 圧縮データを書き込む出力ストリーム。
      戻り値:
      デコンプレッサの入力ストリーム。
      例外:
      IOExceptionSE - IO 例外

    • getEncoding

      protected abstract StringSE getEncoding()
      エンコーディングを取得します。
      戻り値:
      content-encoding ヘッダー。