Chapter 203. LZF Deflate Compression DataFormat

The LZF Deflate Compression dataformat supports 2 options which are listed below.

In this example we marshal a regular text/XML payload to a compressed payload employing LZF compression format and send it an ActiveMQ queue called MY_QUEUE.

from("direct:start").marshal().lzf().to("activemq:queue:MY_QUEUE");

from("direct:start").marshal().lzf().to("activemq:queue:MY_QUEUE");

In this example we unmarshal a LZF payload from an ActiveMQ queue called MY_QUEUE to its original format, and forward it for processing to the UnGZippedMessageProcessor.

from("activemq:queue:MY_QUEUE").unmarshal().lzf().process(new UnCompressedMessageProcessor());

from("activemq:queue:MY_QUEUE").unmarshal().lzf().process(new UnCompressedMessageProcessor());

To useLZF compression in your camel routes you need to add a dependency on camel-lzf which implements this data format.

If you use Maven you can just add the following to your pom.xml, substituting the version number for the latest & greatest release (see https://cwiki.apache.org/confluence/display/CAMEL/Download[the download page for the latest versions]).

<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-lzf</artifactId>
  <version>x.x.x</version>
  <!-- use the same version as your Camel core version -->
</dependency>

<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-lzf</artifactId>
  <version>x.x.x</version>
  <!-- use the same version as your Camel core version -->
</dependency>