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

クラス AbstractCompressingPostProcessor

java.lang.ObjectSE
org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
実装されたすべてのインターフェース:
MessagePostProcessor, Ordered
既知の直属サブクラス
AbstractDeflaterPostProcessor
public abstract class AbstractCompressingPostProcessor extends ObjectSE implements MessagePostProcessor, Ordered
メッセージ本文を圧縮するポストプロセッサーの基本クラス。コンテンツのエンコーディングは、getEncoding() または getEncoding() + ":" + 既存のエンコーディング (存在する場合) に設定されます。
導入:
1.4.2
作成者:
Gary Russell, Artem Bilan

  • フィールドの詳細

    • logger

      protected final Log logger

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

    • AbstractCompressingPostProcessor

      public AbstractCompressingPostProcessor()
      "true" に設定された MessageProperties.SPRING_AUTO_DECOMPRESS ヘッダーを含むポストプロセッサーを構築します。

    • AbstractCompressingPostProcessor

      public AbstractCompressingPostProcessor(boolean autoDecompress)
      MessageProperties.SPRING_AUTO_DECOMPRESS ヘッダーを含む (または含まない) ポストプロセッサーを構築します。(Spring AMQP) 受信・メッセージコンバーターによって使用され、メッセージを自動的に解凍するか、圧縮したままにするかを決定します。
      パラメーター:
      autoDecompress - 受信者が自動的に解凍する必要があることを示す場合は true。

  • メソッドの詳細

    • setCopyProperties

      public void setCopyProperties(boolean copyProperties)
      MessageProperties をそのまま使用するか、圧縮後に新しいメッセージ用に複製するかを示すフラグ。ほとんどの場合、元のメッセージはもう使用されないため、デフォルトでは、パフォーマンスを向上させるためにこのフラグはオフになっています。
      パラメーター:
      copyProperties - 元のメッセージプロパティを複製または再利用します。
      導入:
      2.1.5

    • setEncodingDelimiter

      public void setEncodingDelimiter(StringSE encodingDelimiter)
      圧縮型と元のエンコーディングの間に区切り文字があれば追加するように設定します。デフォルトは ", " (2.3 以降)。2.2.12 よりも前のバージョンの spring-amqp を使用しているコンシューマーとの互換性のために、":" (末尾のスペースなし) に設定します。
      パラメーター:
      encodingDelimiter - 区切り文字。
      導入:
      2.2.12

    • postProcessMessage

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

    • getOrder

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

    • setOrder

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

    • getCompressorStream

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

    • getEncoding

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