Class UnzipPostProcessor
- java.lang.Object
-
- org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
-
- org.springframework.amqp.support.postprocessor.UnzipPostProcessor
-
- All Implemented Interfaces:
MessagePostProcessor
,Ordered
public class UnzipPostProcessor extends AbstractDecompressingPostProcessor
A post processor that uses aZipInputStream
to decompress the message body.- Since:
- 1.4.2
- Author:
- Gary Russell
-
-
Field Summary
-
Fields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
-
-
Constructor Summary
Constructors Constructor Description UnzipPostProcessor()
UnzipPostProcessor(boolean alwaysDecompress)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected InputStream
getDecompressorStream(InputStream zipped)
Get the stream.protected String
getEncoding()
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:AbstractDecompressingPostProcessor
Get the stream.- Specified by:
getDecompressorStream
in 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:AbstractDecompressingPostProcessor
Get the encoding.- Specified by:
getEncoding
in classAbstractDecompressingPostProcessor
- Returns:
- the content-encoding header.
-
-