public abstract class AbstractCompressingPostProcessor extends java.lang.Object implements MessagePostProcessor, org.springframework.core.Ordered
getEncoding()
or getEncoding()
+ ":" + existing encoding, if
present.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 java.io.OutputStream |
getCompressorStream(java.io.OutputStream stream)
Get the stream.
|
protected abstract java.lang.String |
getEncoding()
Get the encoding.
|
int |
getOrder() |
Message |
postProcessMessage(Message message)
Change (or replace) the message.
|
protected void |
setOrder(int order)
Set the order.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
postProcessMessage
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.public int getOrder()
getOrder
in interface org.springframework.core.Ordered
protected void setOrder(int order)
order
- the order, default 0.Ordered
protected abstract java.io.OutputStream getCompressorStream(java.io.OutputStream stream) throws java.io.IOException
stream
- The output stream to write the compressed data to.java.io.IOException
- IOExceptionprotected abstract java.lang.String getEncoding()