public class DelegatingDecompressingPostProcessor extends java.lang.Object implements MessagePostProcessor, org.springframework.core.Ordered
MessagePostProcessor that delegates to one of its MessagePostProcessors
depending on the content encoding. Supports gzip, zip by default.| Constructor and Description |
|---|
DelegatingDecompressingPostProcessor() |
| Modifier and Type | Method and Description |
|---|---|
void |
addDecompressor(java.lang.String contentEncoding,
MessagePostProcessor decompressor)
Add a message post processor to the map of decompressing MessageProcessors.
|
int |
getOrder() |
Message |
postProcessMessage(Message message) |
MessagePostProcessor |
removeDecompressor(java.lang.String contentEncoding)
Remove the decompressor for this encoding; content will not be decompressed even if the
MessageProperties.SPRING_AUTO_DECOMPRESS header is true. |
void |
setDecompressors(java.util.Map<java.lang.String,MessagePostProcessor> decompressors)
Replace all the decompressors.
|
void |
setOrder(int order) |
public DelegatingDecompressingPostProcessor()
public int getOrder()
getOrder in interface org.springframework.core.Orderedpublic void setOrder(int order)
order - the order.Orderedpublic void addDecompressor(java.lang.String contentEncoding,
MessagePostProcessor decompressor)
contentEncoding - the content encoding; messages will be decompressed with this post processor
if its content-encoding property matches, or begins with this key followed by ":".decompressor - the decompressing MessagePostProcessor.public MessagePostProcessor removeDecompressor(java.lang.String contentEncoding)
MessageProperties.SPRING_AUTO_DECOMPRESS header is true.contentEncoding - the content encoding.public void setDecompressors(java.util.Map<java.lang.String,MessagePostProcessor> decompressors)
decompressors - the decompressors.public Message postProcessMessage(Message message) throws AmqpException
postProcessMessage in interface MessagePostProcessorAmqpException