Package org.springframework.amqp.support.postprocessor

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 a InflaterInputStream to 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

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

Constructor Details

InflaterPostProcessor

public InflaterPostProcessor()

InflaterPostProcessor

public InflaterPostProcessor(boolean alwaysDecompress)

Method Details

getDecompressorStream

protected InputStream getDecompressorStream(InputStream zipped)
                                     throws IOException

Description copied from class: AbstractDecompressingPostProcessor

Get the stream.

Specified by:

getDecompressorStream in class AbstractDecompressingPostProcessor

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 class AbstractDecompressingPostProcessor

Returns:

the content-encoding header.