クラス 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
フィールドサマリー
フィールド 修飾子と型 フィールド 説明 protected Log
logger
インターフェース org.springframework.core.Ordered から継承されたフィールド
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
コンストラクターのサマリー
コンストラクター コンストラクター 説明 AbstractCompressingPostProcessor()
"true" に設定されたMessageProperties.SPRING_AUTO_DECOMPRESS
ヘッダーを含むポストプロセッサーを構築します。AbstractCompressingPostProcessor(boolean autoDecompress)
MessageProperties.SPRING_AUTO_DECOMPRESS
ヘッダーを含む (または含まない) ポストプロセッサーを構築します。
メソッドのサマリー
すべてのメソッド インスタンスメソッド 抽象メソッド 具象メソッド 修飾子と型 メソッド 説明 protected abstract OutputStreamSE
getCompressorStream(OutputStreamSE stream)
ストリームを取得します。protected abstract StringSE
getEncoding()
エンコーディングを取得します。int
getOrder()
Message
postProcessMessage(Message message)
メッセージを変更 (または置換) します。void
setCopyProperties(boolean copyProperties)
MessageProperties
をそのまま使用するか、圧縮後に新しいメッセージ用に複製するかを示すフラグ。void
setEncodingDelimiter(StringSE encodingDelimiter)
圧縮型と元のエンコーディングの間に区切り文字があれば追加するように設定します。protected void
setOrder(int order)
順序を設定します。クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.amqp.core.MessagePostProcessor から継承されたメソッド
postProcessMessage, postProcessMessage
フィールドの詳細
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
- 例外。
setOrder
protected void setOrder(int order)
順序を設定します。- パラメーター:
order
- 順序、デフォルトは 0。- 関連事項:
Ordered
getCompressorStream
protected abstract OutputStreamSE getCompressorStream(OutputStreamSE stream) throws IOExceptionSE
ストリームを取得します。- パラメーター:
stream
- 圧縮データを書き込む出力ストリーム。- 戻り値:
- コンプレッサー出力ストリーム。
- 例外:
IOExceptionSE
- IO 例外
getEncoding
protected abstract StringSE getEncoding()
エンコーディングを取得します。- 戻り値:
- content-encoding ヘッダー。