Class InflaterPostProcessor
- java.lang.Object
-
- org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
-
- org.springframework.amqp.support.postprocessor.InflaterPostProcessor
-
- All Implemented Interfaces:
MessagePostProcessor,Ordered
public class InflaterPostProcessor extends AbstractDecompressingPostProcessor
A post processor that uses aInflaterInputStreamto decompress the message body.- Since:
- 2.2
- Author:
- David Diehl
-
-
Field Summary
-
Fields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
-
-
Constructor Summary
Constructors Constructor Description InflaterPostProcessor()InflaterPostProcessor(boolean alwaysDecompress)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected InputStreamgetDecompressorStream(InputStream zipped)Get the stream.protected StringgetEncoding()Get the encoding.-
Methods inherited from class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
getOrder, postProcessMessage, setOrder
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.springframework.amqp.core.MessagePostProcessor
postProcessMessage, postProcessMessage
-
-
-
-
Method Detail
-
getDecompressorStream
protected InputStream getDecompressorStream(InputStream zipped) throws IOException
Description copied from class:AbstractDecompressingPostProcessorGet the stream.- Specified by:
getDecompressorStreamin classAbstractDecompressingPostProcessor- Parameters:
zipped- The output stream to write the compressed data to.- Returns:
- the decompressor input stream.
- Throws:
IOException- IOException
-
getEncoding
protected String getEncoding()
Description copied from class:AbstractDecompressingPostProcessorGet the encoding.- Specified by:
getEncodingin classAbstractDecompressingPostProcessor- Returns:
- the content-encoding header.
-
-