Zip Deflater
Since Camel 2.12
The Zip Deflater Data Format is a message compression and decompression format. Messages marshaled using Zip compression can be unmarshalled using Zip decompression just prior to being consumed at the endpoint. The compression capability is quite useful when you deal with large XML and Text based payloads. It facilitates more optimal use of network bandwidth while incurring a small cost to compress and decompress payloads at the endpoint.
This dataformat is not for working with zip files such as uncompressing and building zip files. Instead, use the zipfile dataformat. |
Options
The Zip Deflater dataformat supports 1 options, which are listed below.
Name | Default | Java Type | Description |
---|---|---|---|
|
|
To specify a specific compression between 0-9. -1 is default compression, 0 is no compression, and 9 is the best compression. Enum values:
|
Marshal
In this example we marshal a regular text/XML payload to a compressed
payload employing zip compression Deflater.BEST_COMPRESSION
and send
it an ActiveMQ queue called MY_QUEUE.
from("direct:start").marshal().zipDeflater(Deflater.BEST_COMPRESSION).to("activemq:queue:MY_QUEUE");
Alternatively, if you would like to use the default setting, you could send it as
from("direct:start").marshal().zipDeflater().to("activemq:queue:MY_QUEUE");
Unmarshal
In this example, we unmarshal a zipped payload from an ActiveMQ queue called MY_QUEUE to its original format, and forward it for processing to the UnZippedMessageProcessor. Note that the compression Level employed during marshaling should be identical to the one employed during unmarshalling to avoid errors.
from("activemq:queue:MY_QUEUE").unmarshal().zipDeflater().process(new UnZippedMessageProcessor());
Dependencies
If you use Maven you could add the following to your pom.xml
, substituting the version number for the latest and greatest release (see the download page for the latest versions).
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-zip-deflater</artifactId>
<version>x.x.x</version>
</dependency>