public abstract class AbstractCompressingPostProcessor extends Object implements MessagePostProcessor, Ordered
getEncoding()
or getEncoding()
+ ":" + existing encoding, if
present.HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
AbstractCompressingPostProcessor()
Construct a post processor that will include the
MessageProperties.SPRING_AUTO_DECOMPRESS header set to 'true'. |
AbstractCompressingPostProcessor(boolean autoDecompress)
Construct a post processor that will include (or not include) the
MessageProperties.SPRING_AUTO_DECOMPRESS header. |
Modifier and Type | Method and Description |
---|---|
protected abstract OutputStream |
getCompressorStream(OutputStream stream) |
protected abstract String |
getEncoding() |
int |
getOrder() |
Message |
postProcessMessage(Message message)
Change (or replace) the message.
|
protected void |
setOrder(int order) |
public AbstractCompressingPostProcessor()
MessageProperties.SPRING_AUTO_DECOMPRESS
header set to 'true'.public AbstractCompressingPostProcessor(boolean autoDecompress)
MessageProperties.SPRING_AUTO_DECOMPRESS
header. Used by the (Spring AMQP) inbound
message converter to determine whether the message should be decompressed
automatically, or remain compressed.autoDecompress
- true to indicate the receiver should automatically
decompress.public Message postProcessMessage(Message message) throws AmqpException
MessagePostProcessor
postProcessMessage
in interface MessagePostProcessor
message
- the message.AmqpException
- an exception.protected void setOrder(int order)
order
- the order, default 0.Ordered
protected abstract OutputStream getCompressorStream(OutputStream stream) throws IOException
stream
- The output stream to write the compressed data to.IOException
- IOExceptionprotected abstract String getEncoding()