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) |
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
postProcessMessage in interface MessagePostProcessorAmqpExceptionprotected void setOrder(int order)
order - the order, default 0.Orderedprotected abstract OutputStream getCompressorStream(OutputStream stream) throws IOException
stream - The output stream to write the compressed data to.IOException - IOExceptionprotected abstract String getEncoding()