Modified: websites/production/camel/content/hazelcast-component.html
==============================================================================
--- websites/production/camel/content/hazelcast-component.html (original)
+++ websites/production/camel/content/hazelcast-component.html Fri Sep 11
12:21:06 2015
@@ -86,564 +86,584 @@
<tr>
<td valign="top" width="100%">
<div class="wiki-content maincontent"><h2
id="HazelcastComponent-HazelcastComponent">Hazelcast
Component</h2><p><strong>Available as of Camel 2.7</strong></p><p>The
<strong>hazelcast:</strong> component allows you to work with the <a
shape="rect" class="external-link" href="http://www.hazelcast.com";
rel="nofollow">Hazelcast</a> distributed data grid / cache. Hazelcast is a in
memory data grid, entirely written in Java (single jar). It offers a great
palette of different data stores like map, multi map (same key, n values),
queue, list and atomic number. The main reason to use Hazelcast is its simple
cluster support. If you have enabled multicast on your network you can run a
cluster with hundred nodes with no extra configuration. Hazelcast can simply
configured to add additional features like n copies between nodes (default is
1), cache persistence, network configuration (if needed), near cache, enviction
and so on. For more information consult the Hazelcast documentation on <a shap
e="rect" class="external-link" href="http://www.hazelcast.com/docs.jsp";
rel="nofollow">http://www.hazelcast.com/docs.jsp</a>.</p><p>Maven users will
need to add the following dependency to their <code>pom.xml</code> for this
component:</p><div class="code panel pdl" style="border-width: 1px;"><div
class="codeContent panelContent pdl">
-<pre class="brush: xml; gutter: false; theme: Default"
style="font-size:12px;"><dependency>
+<script class="brush: xml; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-hazelcast</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel core version -->
</dependency>
-</pre>
+]]></script>
</div></div><h3 id="HazelcastComponent-URIformat">URI format</h3><div
class="code panel pdl" style="border-width: 1px;"><div class="codeContent
panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">hazelcast:[ map | multimap | queue | topic | seda | set
| atomicvalue | instance | list]:cachename[?options]
-</pre>
-</div></div><div class="confluence-information-macro
confluence-information-macro-information"><span class="aui-icon aui-icon-small
aui-iconfont-info confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>Topic support is available as of
Camel 2.15. </p></div></div><p> </p><h3
id="HazelcastComponent-Options">Options</h3><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh">Name</th><th colspan="1" rowspan="1"
class="confluenceTh">Required</th><th colspan="1" rowspan="1"
class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd">hazelcastInstance</td><td colspan="1" rowspan="1"
class="confluenceTd">No</td><td colspan="1" rowspan="1"
class="confluenceTd"><strong>Camel 2.14:</strong><span> The hazelcast instance
<strong>reference</strong> which can be used for hazelcast endpoint. If you
don't specify the instance reference, camel use the defaul
t hazelcast instance from the camel-hazelcast
instance.</span></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd">hazelcastInstanceName</td><td colspan="1" rowspan="1"
class="confluenceTd">No</td><td colspan="1" rowspan="1"
class="confluenceTd"><strong>Camel 2.16:</strong><span> The hazelcast instance
<strong>reference name</strong> which can be used for hazelcast endpoint. If
you don't specify the instance reference, camel use the default hazelcast
instance from the camel-hazelcast instance.</span></td></tr><tr><td colspan="1"
rowspan="1" class="confluenceTd">operation</td><td colspan="1" rowspan="1"
class="confluenceTd">-1</td><td colspan="1" rowspan="1"
class="confluenceTd"><span>To specify a default operation to use, if no
operation header has been provided. </span><strong>deprecated</strong><span>
use defaultOperation instead.</span></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><span>defaultOperation</span></td><td colspan="1"
rowspan="1" class="conf
luenceTd">-1</td><td colspan="1" rowspan="1"
class="confluenceTd"><strong>Camel 2.15:</strong><span> To specify a default
operation to use, if no operation header has been
provided.</span></td></tr></tbody></table></div><div
class="confluence-information-macro confluence-information-macro-warning"><span
class="aui-icon aui-icon-small aui-iconfont-error
confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>You have to use the second prefix
to define which type of data store you want to use.</p></div></div><h3
id="HazelcastComponent-Sections">Sections</h3><ol><li>Usage of <a shape="rect"
href="hazelcast-component.html">#map</a></li><li>Usage of <a shape="rect"
href="hazelcast-component.html">#multimap</a></li><li>Usage of <a shape="rect"
href="hazelcast-component.html">#queue</a></li><li>Usage of <a shape="rect"
href="hazelcast-component.html">#topic</a></li><li>Usage of <a shape="rect"
href="hazelcast-component.html">#list</a></li><li>Usage of <a
shape="rect" href="hazelcast-component.html">#seda</a></li><li>Usage of <a
shape="rect" href="hazelcast-component.html">atomic number</a></li><li>Usage of
<a shape="rect" href="hazelcast-component.html">#cluster</a> support
(instance)</li><li>Usage of <a shape="rect"
href="hazelcast-component.html">#replicatedmap</a> </li></ol><p><span
class="confluence-anchor-link" id="HazelcastComponent-map"></span></p><h3
id="HazelcastComponent-UsageofMap">Usage of Map</h3><h4
id="HazelcastComponent-mapcacheproducer-to("hazelcast:map:foo")">map
cache producer - to("hazelcast:map:foo")</h4><p>If you want to store a value in
a map you can use the map cache producer. The map cache producer provides 5
operations (put, get, update, delete, query). For the first 4 you have to
provide the operation inside the "hazelcast.operation.type" header variable. In
Java DSL you can use the constants from
<code>org.apache.camel.component.hazelcast.HazelcastConstants</code>.</p><p>Header
Variables f
or the request message:</p><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>hazelcast.operation.type</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>valid values are: put, delete,
get, update, query</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.objectId</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p>the object id to store / find your object
inside the cache (not needed for the query
operation)</p></td></tr></tbody></table></div><div
class="confluence-information-macro
confluence-information-macro-warning"><span class="aui-icon aui-icon-small
aui-iconfont-error confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>Header variables have changed in
Camel 2.8</p></div></div><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastOperationType</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>valid values are: put, delete,
get, update, query <strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p><p><strong><strong>From Camel 2.16:</strong></strong>
getAll, putIfAbsent, clear.</p></td></tr><tr><td colspan="1
" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastObjectId</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the object id to store / find
your object inside the cache (not needed for the query operation) <strong><a
shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr></tbody></table></div><p>You can call the samples
with:</p><div class="code panel pdl" style="border-width: 1px;"><div
class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">template.sendBodyAndHeader("direct:[put|get|update|delete|query]",
"my-foo", HazelcastConstants.OBJECT_ID, "4711");
-</pre>
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[hazelcast:[ map | multimap | queue | topic |
seda | set | atomicvalue | instance | list | ringbuffer]:cachename[?options]
+]]></script>
+</div></div><div class="confluence-information-macro
confluence-information-macro-information"><span class="aui-icon aui-icon-small
aui-iconfont-info confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>Topic support is available as of
Camel 2.15. </p></div></div><div class="confluence-information-macro
confluence-information-macro-information"><span class="aui-icon aui-icon-small
aui-iconfont-info confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>RingBuffer support is available as
of Camel 2.16. </p></div></div><h3
id="HazelcastComponent-Options">Options</h3><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh">Name</th><th colspan="1" rowspan="1"
class="confluenceTh">Required</th><th colspan="1" rowspan="1"
class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd">hazelcastInstance</td><td colsp
an="1" rowspan="1" class="confluenceTd">No</td><td colspan="1" rowspan="1"
class="confluenceTd"><strong>Camel 2.14:</strong><span> The hazelcast instance
<strong>reference</strong> which can be used for hazelcast endpoint. If you
don't specify the instance reference, camel use the default hazelcast instance
from the camel-hazelcast instance.</span></td></tr><tr><td colspan="1"
rowspan="1" class="confluenceTd">hazelcastInstanceName</td><td colspan="1"
rowspan="1" class="confluenceTd">No</td><td colspan="1" rowspan="1"
class="confluenceTd"><strong>Camel 2.16:</strong><span> The hazelcast instance
<strong>reference name</strong> which can be used for hazelcast endpoint. If
you don't specify the instance reference, camel use the default hazelcast
instance from the camel-hazelcast instance.</span></td></tr><tr><td colspan="1"
rowspan="1" class="confluenceTd">operation</td><td colspan="1" rowspan="1"
class="confluenceTd">-1</td><td colspan="1" rowspan="1"
class="confluenceTd"><span>To spe
cify a default operation to use, if no operation header has been provided.
</span><strong>deprecated</strong><span> use defaultOperation
instead.</span></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><span>defaultOperation</span></td><td colspan="1"
rowspan="1" class="confluenceTd">-1</td><td colspan="1" rowspan="1"
class="confluenceTd"><strong>Camel 2.15:</strong><span> To specify a default
operation to use, if no operation header has been
provided.</span></td></tr></tbody></table></div><div
class="confluence-information-macro confluence-information-macro-warning"><span
class="aui-icon aui-icon-small aui-iconfont-error
confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>You have to use the second prefix
to define which type of data store you want to use.</p></div></div><h3
id="HazelcastComponent-Sections">Sections</h3><ol><li>Usage of <a shape="rect"
href="#HazelcastComponent-map">#map</a></li><li>Usage of <a shape="rect" href=
"#HazelcastComponent-multimap">#multimap</a></li><li>Usage of <a shape="rect"
href="#HazelcastComponent-queue">#queue</a></li><li>Usage of <a shape="rect"
href="#HazelcastComponent-topic">#topic</a></li><li>Usage of <a shape="rect"
href="#HazelcastComponent-list">#list</a></li><li>Usage of <a shape="rect"
href="#HazelcastComponent-seda">#seda</a></li><li>Usage of <a shape="rect"
href="#HazelcastComponent-atomicnumber">atomic number</a></li><li>Usage of <a
shape="rect" href="#HazelcastComponent-cluster">#cluster</a> support
(instance)</li><li>Usage of <a shape="rect"
href="#HazelcastComponent-replicatedmap">#replicatedmap</a> </li><li>Usage
of <a shape="rect"
href="#HazelcastComponent-ringbuffer">#ringbuffer</a> </li></ol><p><span
class="confluence-anchor-link" id="HazelcastComponent-map"></span></p><h3
id="HazelcastComponent-UsageofMap">Usage of Map</h3><h4
id="HazelcastComponent-mapcacheproducer-to("hazelcast:map:foo")">map
cache producer - to("hazelcast:ma
p:foo")</h4><p>If you want to store a value in a map you can use the map cache
producer. The map cache producer provides 5 operations (put, get, update,
delete, query). For the first 4 you have to provide the operation inside the
"hazelcast.operation.type" header variable. In Java DSL you can use the
constants from
<code>org.apache.camel.component.hazelcast.HazelcastConstants</code>.</p><p>Header
Variables for the request message:</p><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>hazelcast.operation.type</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>valid values are: put, delete,
get, update, query</p
></td></tr><tr><td colspan="1" rowspan="1"
>class="confluenceTd"><p><code>hazelcast.objectId</code></p></td><td
>colspan="1" rowspan="1"
>class="confluenceTd"><p><code>String</code></p></td><td colspan="1"
>rowspan="1" class="confluenceTd"><p>the object id to store / find your object
>inside the cache (not needed for the query
>operation)</p></td></tr></tbody></table></div><div
>class="confluence-information-macro
>confluence-information-macro-warning"><span class="aui-icon aui-icon-small
>aui-iconfont-error confluence-information-macro-icon"></span><div
>class="confluence-information-macro-body"><p>Header variables have changed in
>Camel 2.8</p></div></div><div class="table-wrap"><table
>class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
>class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
>class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
>class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
>rowspan="1" class="confluenceTd"><p><code>CamelHa
zelcastOperationType</code></p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>String</code></p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p>valid values are: put, delete, get, update, query
<strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p><p><strong><strong>From Camel 2.16:</strong></strong>
getAll, putIfAbsent, clear.</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastObjectId</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the object id to store / find
your object inside the cache (not needed for the query operation) <strong><a
shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr></tbody></table></div><p>You can call the samples
with:</p><div class="code panel pdl" style="border-width: 1px;"><div
class="codeContent panelContent pdl">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[template.sendBodyAndHeader("direct:[put|get|update|delete|query]",
"my-foo", HazelcastConstants.OBJECT_ID, "4711");
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforput:">Sample for
<strong>put</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:put")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:put")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.PUT_OPERATION))
-.toF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX);
-</pre>
+.toF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX);
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:put" />
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:put" />
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>put</constant>
</setHeader>
- <to uri="hazelcast:map:foo" />
+ <to uri="hazelcast:map:foo" />
</route>
-</pre>
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforget:">Sample for
<strong>get</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:get")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:get")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.GET_OPERATION))
-.toF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX)
-.to("seda:out");
-</pre>
-</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:get" />
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+.toF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX)
+.to("seda:out");
+]]></script>
+</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:get" />
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>get</constant>
</setHeader>
- <to uri="hazelcast:map:foo" />
- <to uri="seda:out" />
+ <to uri="hazelcast:map:foo" />
+ <to uri="seda:out" />
</route>
-</pre>
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforupdate:">Sample for
<strong>update</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:update")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:update")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.UPDATE_OPERATION))
-.toF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX);
-</pre>
+.toF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX);
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:update" />
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:update" />
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>update</constant>
</setHeader>
- <to uri="hazelcast:map:foo" />
+ <to uri="hazelcast:map:foo" />
</route>
-</pre>
+]]></script>
</div></div><h5 id="HazelcastComponent-Samplefordelete:">Sample for
<strong>delete</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:delete")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:delete")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.DELETE_OPERATION))
-.toF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX);
-</pre>
+.toF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX);
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:delete" />
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:delete" />
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>delete</constant>
</setHeader>
- <to uri="hazelcast:map:foo" />
+ <to uri="hazelcast:map:foo" />
</route>
-</pre>
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforquery">Sample for
<strong>query</strong></h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:query")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:query")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.QUERY_OPERATION))
-.toF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX)
-.to("seda:out");
-</pre>
-</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:query" />
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+.toF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX)
+.to("seda:out");
+]]></script>
+</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:query" />
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>query</constant>
</setHeader>
- <to uri="hazelcast:map:foo" />
- <to uri="seda:out" />
+ <to uri="hazelcast:map:foo" />
+ <to uri="seda:out" />
</route>
-</pre>
+]]></script>
</div></div><p>For the query operation Hazelcast offers a SQL like syntax to
query your distributed map.</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">String q1 = "bar > 1000";
-template.sendBodyAndHeader("direct:query", null, HazelcastConstants.QUERY, q1);
-</pre>
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[String q1 = "bar > 1000";
+template.sendBodyAndHeader("direct:query", null,
HazelcastConstants.QUERY, q1);
+]]></script>
</div></div><h3
id="HazelcastComponent-mapcacheconsumer-from("hazelcast:map:foo")">map
cache consumer - from("hazelcast:map:foo")</h3><p>Hazelcast provides event
listeners on their data grid. If you want to be notified if a cache will be
manipulated, you can use the map consumer. There're 4 events:
<strong>put</strong>, <strong>update</strong>, <strong>delete</strong> and
<strong>envict</strong>. The event type will be stored in the
"<strong>hazelcast.listener.action</strong>" header variable. The map consumer
provides some additional information inside these variables:</p><p>Header
Variables inside the response message:</p><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1" class="confluenceTd"><p><code>hazelcast.listener.t
ime</code></p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>Long</code></p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p>time of the event in millis</p></td></tr><tr><td
colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.listener.type</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the map consumer sets here
"cachelistener"</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.listener.action</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>type of event - here
<strong>added</strong>, <strong>updated</strong>, <strong>envicted</strong> and
<strong>removed</strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.objectId</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"
><p><code>String</code></p></td><td colspan="1" rowspan="1"
>class="confluenceTd"><p>the oid of the object</p></td></tr><tr><td
>colspan="1" rowspan="1"
>class="confluenceTd"><p><code>hazelcast.cache.name</code></p></td><td
>colspan="1" rowspan="1"
>class="confluenceTd"><p><code>String</code></p></td><td colspan="1"
>rowspan="1" class="confluenceTd"><p>the name of the cache - e.g.
>"foo"</p></td></tr><tr><td colspan="1" rowspan="1"
>class="confluenceTd"><p><code>hazelcast.cache.type</code></p></td><td
>colspan="1" rowspan="1"
>class="confluenceTd"><p><code>String</code></p></td><td colspan="1"
>rowspan="1" class="confluenceTd"><p>the type of the cache - here
>map</p></td></tr></tbody></table></div><div
>class="confluence-information-macro
>confluence-information-macro-warning"><span class="aui-icon aui-icon-small
>aui-iconfont-error confluence-information-macro-icon"></span><div
>class="confluence-information-macro-body"><p>Header variables have changed in
>Camel 2.8</p></div></div><div class="table
-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastListenerTime</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>Long</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>time of the event in millis
<strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastListenerType</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the map consumer sets here
"cachelistener" <strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastListenerAction</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>type of event - here
<strong>added</strong>, <strong>updated</strong>, <strong>envicted</strong> and
<strong>removed</strong>. <strong><a shape="rect" class="unresolved"
href="#">Version 2.8</a></strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastObjectId</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the oid of the object
<strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastCacheName</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="co
nfluenceTd"><p>the name of the cache - e.g. "foo" <strong><a shape="rect"
class="unresolved" href="#">Version 2.8</a></strong></p></td></tr><tr><td
colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastCacheType</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the type of the cache - here
map <strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr></tbody></table></div><p>The object value will be
stored within <strong>put</strong> and <strong>update</strong> actions inside
the message body.</p><p>Here's a sample:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">fromF("hazelcast:%sfoo", HazelcastConstants.MAP_PREFIX)
-.log("object...")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[fromF("hazelcast:%sfoo",
HazelcastConstants.MAP_PREFIX)
+.log("object...")
.choice()
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.ADDED))
- .log("...added")
- .to("mock:added")
+ .log("...added")
+ .to("mock:added")
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.ENVICTED))
- .log("...envicted")
- .to("mock:envicted")
+ .log("...envicted")
+ .to("mock:envicted")
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.UPDATED))
- .log("...updated")
- .to("mock:updated")
+ .log("...updated")
+ .to("mock:updated")
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.REMOVED))
- .log("...removed")
- .to("mock:removed")
+ .log("...removed")
+ .to("mock:removed")
.otherwise()
- .log("fail!");
-</pre>
+ .log("fail!");
+]]></script>
</div></div><p><span class="confluence-anchor-link"
id="HazelcastComponent-multimap"></span></p><h3
id="HazelcastComponent-UsageofMultiMap">Usage of Multi Map</h3><h4
id="HazelcastComponent-multimapcacheproducer-to("hazelcast:multimap:foo")">multimap
cache producer - to("hazelcast:multimap:foo")</h4><p>A multimap is a cache
where you can store n values to one key. The multimap producer provides 4
operations (put, get, removevalue, delete).</p><p>Header Variables for the
request message:</p><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>hazelcast.operation.type</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="co
nfluenceTd"><p>valid values are: put, get, removevalue,
delete</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.objectId</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p>the object id to store / find your object
inside the cache</p></td></tr></tbody></table></div><div
class="confluence-information-macro confluence-information-macro-warning"><span
class="aui-icon aui-icon-small aui-iconfont-error
confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>Header variables have changed in
Camel 2.8</p></div></div><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1" class="co
nfluenceTd"><p><code>CamelHazelcastOperationType</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>valid values are: put, get,
removevalue, delete <strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p><p><strong><strong><strong>From Camel
2.16:</strong></strong></strong> clear.</p></td></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastObjectId</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the object id to store / find
your object inside the cache <strong><a shape="rect" class="unresolved"
href="#">Version 2.8</a></strong></p></td></tr></tbody></table></div><h5
id="HazelcastComponent-Sampleforput:.1">Sample for
<strong>put</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent pan
elContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:put")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:put")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.PUT_OPERATION))
-.to(String.format("hazelcast:%sbar", HazelcastConstants.MULTIMAP_PREFIX));
-</pre>
+.to(String.format("hazelcast:%sbar",
HazelcastConstants.MULTIMAP_PREFIX));
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:put" />
- <log message="put.."/>
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:put" />
+ <log message="put.."/>
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>put</constant>
</setHeader>
- <to uri="hazelcast:multimap:foo" />
+ <to uri="hazelcast:multimap:foo" />
</route>
-</pre>
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforremovevalue:">Sample for
<strong>removevalue</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:removevalue")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:removevalue")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.REMOVEVALUE_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.MULTIMAP_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.MULTIMAP_PREFIX);
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:removevalue" />
- <log message="removevalue..."/>
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:removevalue" />
+ <log message="removevalue..."/>
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>removevalue</constant>
</setHeader>
- <to uri="hazelcast:multimap:foo" />
+ <to uri="hazelcast:multimap:foo" />
</route>
-</pre>
+]]></script>
</div></div><p>To remove a value you have to provide the value you want to
remove inside the message body. If you have a multimap object {<code>key:
"4711" values: { "my-foo", "my-bar"</code>}} you have to put "my-foo" inside
the message body to remove the "my-foo" value.</p><h5
id="HazelcastComponent-Sampleforget:.1">Sample for
<strong>get</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:get")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:get")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.GET_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.MULTIMAP_PREFIX)
-.to("seda:out");
-</pre>
-</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:get" />
- <log message="get.."/>
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+.toF("hazelcast:%sbar", HazelcastConstants.MULTIMAP_PREFIX)
+.to("seda:out");
+]]></script>
+</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:get" />
+ <log message="get.."/>
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>get</constant>
</setHeader>
- <to uri="hazelcast:multimap:foo" />
- <to uri="seda:out" />
+ <to uri="hazelcast:multimap:foo" />
+ <to uri="seda:out" />
</route>
-</pre>
+]]></script>
</div></div><h5 id="HazelcastComponent-Samplefordelete:.1">Sample for
<strong>delete</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:delete")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:delete")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.DELETE_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.MULTIMAP_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.MULTIMAP_PREFIX);
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:delete" />
- <log message="delete.."/>
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:delete" />
+ <log message="delete.."/>
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>delete</constant>
</setHeader>
- <to uri="hazelcast:multimap:foo" />
+ <to uri="hazelcast:multimap:foo" />
</route>
-</pre>
+]]></script>
</div></div><p>you can call them in your test class with:</p><div class="code
panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">template.sendBodyAndHeader("direct:[put|get|removevalue|delete]",
"my-foo", HazelcastConstants.OBJECT_ID, "4711");
-</pre>
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[template.sendBodyAndHeader("direct:[put|get|removevalue|delete]",
"my-foo", HazelcastConstants.OBJECT_ID, "4711");
+]]></script>
</div></div><h4
id="HazelcastComponent-multimapcacheconsumer-from("hazelcast:multimap:foo")">multimap
cache consumer - from("hazelcast:multimap:foo")</h4><p>For the multimap cache
this component provides the same listeners / variables as for the map cache
consumer (except the update and enviction listener). The only difference is the
<strong>multimap</strong> prefix inside the URI. Here is a sample:</p><div
class="code panel pdl" style="border-width: 1px;"><div class="codeContent
panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">fromF("hazelcast:%sbar",
HazelcastConstants.MULTIMAP_PREFIX)
-.log("object...")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[fromF("hazelcast:%sbar",
HazelcastConstants.MULTIMAP_PREFIX)
+.log("object...")
.choice()
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.ADDED))
- .log("...added")
- .to("mock:added")
+ .log("...added")
+ .to("mock:added")
//.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.ENVICTED))
- // .log("...envicted")
- // .to("mock:envicted")
+ // .log("...envicted")
+ // .to("mock:envicted")
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.REMOVED))
- .log("...removed")
- .to("mock:removed")
+ .log("...removed")
+ .to("mock:removed")
.otherwise()
- .log("fail!");
-</pre>
+ .log("fail!");
+]]></script>
</div></div><p>Header Variables inside the response message:</p><div
class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1"
rowspan="1" class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>hazelcast.listener.time</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>Long</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>time of the event in
millis</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.listener.type</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the map consumer sets here
"cachelistener"</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.listener.action</code></p><
/td><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>String</code></p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p>type of event - here <strong>added</strong> and
<strong>removed</strong> (and soon
<strong>envicted</strong>)</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.objectId</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p>the oid of the object</p></td></tr><tr><td
colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.cache.name</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the name of the cache - e.g.
"foo"</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.cache.type</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" row
span="1" class="confluenceTd"><p>the type of the cache - here
multimap</p></td></tr></tbody></table></div><p>Eviction will be added as
feature, soon (this is a Hazelcast issue).</p><div
class="confluence-information-macro confluence-information-macro-warning"><span
class="aui-icon aui-icon-small aui-iconfont-error
confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>Header variables have changed in
Camel 2.8</p></div></div><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastListenerTime</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>Long</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>time of the event in mil
lis <strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastListenerType</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the map consumer sets here
"cachelistener" <strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastListenerAction</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>type of event - here
<strong>added</strong> and <strong>removed</strong> (and soon
<strong>envicted</strong>) <strong><a shape="rect" class="unresolved"
href="#">Version 2.8</a></strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastObjectId</code></p><
/td><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>String</code></p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p>the oid of the object <strong><a shape="rect"
class="unresolved" href="#">Version 2.8</a></strong></p></td></tr><tr><td
colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastCacheName</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the name of the cache - e.g.
"foo" <strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastCacheType</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the type of the cache - here
multimap <strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr></tbody></table></div><p><span
class="confluence-anchor-link" id="HazelcastComponent-queue"></span></p><h3
id="HazelcastComponent-UsageofQueue">Usage of Queue</h3><h4
id="HazelcastComponent-Queueproducer–to(“hazelcast:queue:foo”)">Queue
producer – to(“hazelcast:queue:foo”)</h4><p>The queue
producer provides 6 operations (add, put, poll, peek, offer,
removevalue).</p><h5 id="HazelcastComponent-Sampleforadd:">Sample for
<strong>add</strong>:</h5><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:add")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:add")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.ADD_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforput:.2">Sample for
<strong>put</strong>:</h5><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:put")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:put")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.PUT_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforpoll:">Sample for
<strong>poll</strong>:</h5><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:poll")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:poll")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.POLL_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforpeek:">Sample for
<strong>peek</strong>:</h5><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:peek")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:peek")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.PEEK_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforoffer:">Sample for
<strong>offer</strong>:</h5><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:offer")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:offer")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.OFFER_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforremovevalue:.1">Sample for
<strong>removevalue</strong>:</h5><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:removevalue")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:removevalue")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.REMOVEVALUE_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.QUEUE_PREFIX);
+]]></script>
</div></div><h4
id="HazelcastComponent-Queueconsumer–from(“hazelcast:queue:foo”)">Queue
consumer – from(“hazelcast:queue:foo”)</h4><p>The queue
consumer provides 2 operations (add, remove).</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">fromF("hazelcast:%smm", HazelcastConstants.QUEUE_PREFIX)
- .log("object...")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[fromF("hazelcast:%smm",
HazelcastConstants.QUEUE_PREFIX)
+ .log("object...")
.choice()
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.ADDED))
- .log("...added")
- .to("mock:added")
+ .log("...added")
+ .to("mock:added")
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.REMOVED))
- .log("...removed")
- .to("mock:removed")
+ .log("...removed")
+ .to("mock:removed")
.otherwise()
- .log("fail!");
-</pre>
+ .log("fail!");
+]]></script>
</div></div><h3 id="HazelcastComponent-topic"><span
class="confluence-anchor-link" id="HazelcastComponent-topic"></span></h3><h3
id="HazelcastComponent-UsageofTopic">Usage of Topic</h3><h4
id="HazelcastComponent-Topicproducer–to(“hazelcast:topic:foo”)">Topic
producer – to(“hazelcast:topic:foo”)</h4><p>The topic
producer provides only one operation (publish).</p><h5
id="HazelcastComponent-Sampleforpublish:">Sample
for <strong>publish</strong>:</h5><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:add")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:add")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.PUBLISH_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.PUBLISH_OPERATION);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.PUBLISH_OPERATION);
+]]></script>
</div></div><h4
id="HazelcastComponent-Topicconsumer–from(“hazelcast:topic:foo”)">Topic
consumer – from(“hazelcast:topic:foo”)</h4><p>The topic
consumer provides only one operation (received). This component is supposed to
support multiple consumption as it's expected when it comes to topics so you
are free to have as much consumers as you need on the same hazelcast
topic.</p><div class="code panel pdl" style="border-width: 1px;"><div
class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">fromF("hazelcast:%sfoo",
HazelcastConstants.TOPIC_PREFIX)
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[fromF("hazelcast:%sfoo",
HazelcastConstants.TOPIC_PREFIX)
.choice()
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.RECEIVED))
- .log("...message received")
+ .log("...message received")
.otherwise()
- .log("...this should never have happened")</pre>
+ .log("...this should never have happened")]]></script>
</div></div><p> </p><p><span class="confluence-anchor-link"
id="HazelcastComponent-list"></span></p><h3
id="HazelcastComponent-UsageofList">Usage of List</h3><h4
id="HazelcastComponent-Listproducer–to(“hazelcast:list:foo”)">List
producer – to(“hazelcast:list:foo”)</h4><p>The list producer
provides 4 operations (add, addAll, set, get, removevalue, removeAll,
clear).</p><h5 id="HazelcastComponent-Sampleforadd:.1">Sample for
<strong>add</strong>:</h5><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:add")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:add")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.ADD_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.LIST_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.LIST_PREFIX);
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforget:.2">Sample for
<strong>get</strong>:</h5><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:get")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:get")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.GET_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.LIST_PREFIX)
-.to("seda:out");
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.LIST_PREFIX)
+.to("seda:out");
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforsetvalue:">Sample for
<strong>setvalue</strong>:</h5><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:set")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:set")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.SETVALUE_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.LIST_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.LIST_PREFIX);
+]]></script>
</div></div><h5 id="HazelcastComponent-Sampleforremovevalue:.2">Sample for
<strong>removevalue</strong>:</h5><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:removevalue")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:removevalue")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.REMOVEVALUE_OPERATION))
-.toF("hazelcast:%sbar", HazelcastConstants.LIST_PREFIX);
-</pre>
+.toF("hazelcast:%sbar", HazelcastConstants.LIST_PREFIX);
+]]></script>
</div></div><p>Note that <strong>CamelHazelcastObjectIndex</strong>
header is used for indexing purpose.</p><h4
id="HazelcastComponent-Thelistconsumerprovides2operations(add,remove).Listconsumer–from(“hazelcast:list:foo”)"><span
style="line-height: 1.4285715;">The list consumer provides 2 operations (add,
remove).</span>List consumer –
from(“hazelcast:list:foo”)</h4><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">fromF("hazelcast:%smm", HazelcastConstants.LIST_PREFIX)
- .log("object...")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[fromF("hazelcast:%smm",
HazelcastConstants.LIST_PREFIX)
+ .log("object...")
.choice()
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.ADDED))
- .log("...added")
- .to("mock:added")
+ .log("...added")
+ .to("mock:added")
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.REMOVED))
- .log("...removed")
- .to("mock:removed")
+ .log("...removed")
+ .to("mock:removed")
.otherwise()
- .log("fail!");
-</pre>
+ .log("fail!");
+]]></script>
</div></div><p><span class="confluence-anchor-link"
id="HazelcastComponent-seda"></span></p><h3
id="HazelcastComponent-UsageofSEDA">Usage of SEDA</h3><p>SEDA component differs
from the rest components provided. It implements a work-queue in order to
support asynchronous SEDA architectures, similar to the core "SEDA"
component.</p><h4
id="HazelcastComponent-SEDAproducer–to(“hazelcast:seda:foo”)">SEDA
producer – to(“hazelcast:seda:foo”)</h4><p>The SEDA producer
provides no operations. You only send data to the specified queue.</p><div
class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1"
rowspan="1" class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>default value</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1" class="confluenceTd"><p><code>transferExchange</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p
><code>false</code></p></td><td colspan="1" rowspan="1"
>class="confluenceTd"><p><strong>Camel 2.8.0:</strong> if set to true the
>whole Exchange will be transfered. If header or body contains not
>serializable objects, they will be
>skipped.</p></td></tr></tbody></table></div><p>Java DSL :</p><div class="code
>panel pdl" style="border-width: 1px;"><div class="codeContent panelContent
>pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:foo")
-.to("hazelcast:seda:foo");
-</pre>
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:foo")
+.to("hazelcast:seda:foo");
+]]></script>
</div></div><p>Spring DSL :</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:start" />
- <to uri="hazelcast:seda:foo" />
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:start" />
+ <to uri="hazelcast:seda:foo" />
</route>
-</pre>
+]]></script>
</div></div><h4
id="HazelcastComponent-SEDAconsumer–from(“hazelcast:seda:foo”)">SEDA
consumer – from(“hazelcast:seda:foo”)</h4><p>The SEDA
consumer provides no operations. You only retrieve data from the specified
queue.</p><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th
colspan="1" rowspan="1" class="confluenceTh"><p>Name</p></th><th colspan="1"
rowspan="1" class="confluenceTh"><p>default value</p></th><th colspan="1"
rowspan="1" class="confluenceTh"><p>Description</p></th></tr><tr><td
colspan="1" rowspan="1"
class="confluenceTd"><p><code>pollInterval</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p><code>1000</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p><span>The timeout used when consuming from
the SEDA queue. </span><span style="color: rgb(0,0,0);">When a timeout occurs,
the consumer can check whether it is allowed to continue running. Setting a
lower value allows the consumer to re
act more quickly upon shutdown. (<strong>deprecated</strong> from Camel 2.15
onwards, use pollTimeout instead).</span></p></td></tr><tr><td colspan="1"
rowspan="1" class="confluenceTd"><code>pollTimeout</code></td><td colspan="1"
rowspan="1" class="confluenceTd">1000</td><td colspan="1" rowspan="1"
class="confluenceTd"><strong>Camel 2.15:</strong> The timeout used when
consuming from the SEDA queue. <span style="color: rgb(0,0,0);">When a timeout
occurs, the consumer can check whether it is allowed to continue running.
Setting a lower value allows the consumer to react more quickly upon
shutdown.</span></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>concurrentConsumers</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>1</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>To use concurrent consumers
polling from the SEDA queue.</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>transferExchange</cod
e></p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>false</code></p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p><strong>Camel 2.8.0:</strong> if set to true the whole
Exchange will be transfered. If header or body contains not serializable
objects, they will be skipped.</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>transacted</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p><code>false</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p><strong>Camel 2.10.4:</strong> if set to
true then the consumer runs in transaction mode, where the messages in the seda
queue will only be removed if the transaction commits, which happens when the
processing is complete.</p></td></tr></tbody></table></div><p>Java DSL
:</p><div class="code panel pdl" style="border-width: 1px;"><div
class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("hazelcast:seda:foo")
-.to("mock:result");
-</pre>
-</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="hazelcast:seda:foo" />
- <to uri="mock:result" />
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("hazelcast:seda:foo")
+.to("mock:result");
+]]></script>
+</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="hazelcast:seda:foo" />
+ <to uri="mock:result" />
</route>
-</pre>
+]]></script>
</div></div><p><span class="confluence-anchor-link"
id="HazelcastComponent-atomicnumber"></span></p><h3
id="HazelcastComponent-UsageofAtomicNumber">Usage of Atomic Number</h3><div
class="confluence-information-macro confluence-information-macro-warning"><span
class="aui-icon aui-icon-small aui-iconfont-error
confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>There is no consumer for this
endpoint!</p></div></div><h4
id="HazelcastComponent-atomicnumberproducer-to("hazelcast:atomicnumber:foo")">atomic
number producer - to("hazelcast:atomicnumber:foo")</h4><p>An atomic number is
an object that simply provides a grid wide number (long). The operations for
this producer are setvalue (set the number with a given value), get, increase
(+1), decrease (-1) and destroy.</p><p>Header Variables for the request
message:</p><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</
p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Type</p></th><th
colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>hazelcast.operation.type</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>valid values are: setvalue,
get, increase, decrease, destroy</p></td></tr></tbody></table></div><div
class="confluence-information-macro confluence-information-macro-warning"><span
class="aui-icon aui-icon-small aui-iconfont-error
confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>Header variables have changed in
Camel 2.8</p></div></div><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1" class="co
nfluenceTh"><p>Description</p></th></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastOperationType</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>valid values are: setvalue,
get, increase, decrease, destroy <strong>Available as of Camel version
2.8</strong></p></td></tr></tbody></table></div><h5
id="HazelcastComponent-Sampleforset:">Sample for
<strong>set</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:set")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:set")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.SETVALUE_OPERATION))
-.toF("hazelcast:%sfoo", HazelcastConstants.ATOMICNUMBER_PREFIX);
-</pre>
+.toF("hazelcast:%sfoo", HazelcastConstants.ATOMICNUMBER_PREFIX);
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:set" />
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:set" />
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>setvalue</constant>
</setHeader>
- <to uri="hazelcast:atomicvalue:foo" />
+ <to uri="hazelcast:atomicvalue:foo" />
</route>
-</pre>
+]]></script>
</div></div><p>Provide the value to set inside the message body (here the
value is 10): <code>template.sendBody("direct:set", 10);</code></p><h5
id="HazelcastComponent-Sampleforget:.3">Sample for
<strong>get</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:get")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:get")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.GET_OPERATION))
-.toF("hazelcast:%sfoo", HazelcastConstants.ATOMICNUMBER_PREFIX);
-</pre>
+.toF("hazelcast:%sfoo", HazelcastConstants.ATOMICNUMBER_PREFIX);
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:get" />
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:get" />
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>get</constant>
</setHeader>
- <to uri="hazelcast:atomicvalue:foo" />
+ <to uri="hazelcast:atomicvalue:foo" />
</route>
-</pre>
+]]></script>
</div></div><p>You can get the number with <code>long body =
template.requestBody("direct:get", null, Long.class);</code>.</p><h5
id="HazelcastComponent-Sampleforincrement:">Sample for
<strong>increment</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:increment")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:increment")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.INCREMENT_OPERATION))
-.toF("hazelcast:%sfoo", HazelcastConstants.ATOMICNUMBER_PREFIX);
-</pre>
+.toF("hazelcast:%sfoo", HazelcastConstants.ATOMICNUMBER_PREFIX);
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:increment" />
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:increment" />
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>increment</constant>
</setHeader>
- <to uri="hazelcast:atomicvalue:foo" />
+ <to uri="hazelcast:atomicvalue:foo" />
</route>
-</pre>
+]]></script>
</div></div><p>The actual value (after increment) will be provided inside the
message body.</p><h5 id="HazelcastComponent-Samplefordecrement:">Sample for
<strong>decrement</strong>:</h5><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:decrement")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:decrement")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.DECREMENT_OPERATION))
-.toF("hazelcast:%sfoo", HazelcastConstants.ATOMICNUMBER_PREFIX);
-</pre>
+.toF("hazelcast:%sfoo", HazelcastConstants.ATOMICNUMBER_PREFIX);
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:decrement" />
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:decrement" />
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>decrement</constant>
</setHeader>
- <to uri="hazelcast:atomicvalue:foo" />
+ <to uri="hazelcast:atomicvalue:foo" />
</route>
-</pre>
+]]></script>
</div></div><p>The actual value (after decrement) will be provided inside the
message body.</p><h5 id="HazelcastComponent-Samplefordestroy">Sample for
<strong>destroy</strong></h5><div class="confluence-information-macro
confluence-information-macro-warning"><span class="aui-icon aui-icon-small
aui-iconfont-error confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>There's a bug inside Hazelcast. So
this feature may not work properly. Will be fixed in
1.9.3.</p></div></div><p>Java DSL:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">from("direct:destroy")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[from("direct:destroy")
.setHeader(HazelcastConstants.OPERATION,
constant(HazelcastConstants.DESTROY_OPERATION))
-.toF("hazelcast:%sfoo", HazelcastConstants.ATOMICNUMBER_PREFIX);
-</pre>
+.toF("hazelcast:%sfoo", HazelcastConstants.ATOMICNUMBER_PREFIX);
+]]></script>
</div></div><p>Spring DSL:</p><div class="code panel pdl" style="border-width:
1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;"><route>
- <from uri="direct:destroy" />
- <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
- <setHeader headerName="hazelcast.operation.type">
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<route>
+ <from uri="direct:destroy" />
+ <!-- If using version 2.8 and above set headerName to
"CamelHazelcastOperationType" -->
+ <setHeader headerName="hazelcast.operation.type">
<constant>destroy</constant>
</setHeader>
- <to uri="hazelcast:atomicvalue:foo" />
+ <to uri="hazelcast:atomicvalue:foo" />
</route>
-</pre>
+]]></script>
</div></div><p><span class="confluence-anchor-link"
id="HazelcastComponent-cluster"></span></p><h3
id="HazelcastComponent-clustersupport">cluster support</h3><div
class="confluence-information-macro confluence-information-macro-warning"><span
class="aui-icon aui-icon-small aui-iconfont-error
confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>This endpoint provides no
producer!</p></div></div><h3
id="HazelcastComponent-instanceconsumer-from("hazelcast:instance:foo")">instance
consumer - from("hazelcast:instance:foo")</h3><p>Hazelcast makes sense in one
single "server node", but it's extremly powerful in a clustered environment.
The instance consumer fires if a new cache instance will join or leave the
cluster.</p><p>Here's a sample:</p><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: java; gutter: false; theme: Default"
style="font-size:12px;">fromF("hazelcast:%sfoo",
HazelcastConstants.INSTANCE_PREFIX)
-.log("instance...")
+<script class="brush: java; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[fromF("hazelcast:%sfoo",
HazelcastConstants.INSTANCE_PREFIX)
+.log("instance...")
.choice()
.when(header(HazelcastConstants.LISTENER_ACTION).isEqualTo(HazelcastConstants.ADDED))
- .log("...added")
- .to("mock:added")
+ .log("...added")
+ .to("mock:added")
.otherwise()
- .log("...removed")
- .to("mock:removed");
-</pre>
+ .log("...removed")
+ .to("mock:removed");
+]]></script>
</div></div><p>Each event provides the following information inside the
message header:</p><p>Header Variables inside the response message:</p><div
class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1"
rowspan="1" class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>hazelcast.listener.time</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>Long</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>time of the event in
millis</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.listener.type</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>the map consumer sets here
"instancelistener"</p></td></tr><tr><td colspan="
1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.listener.action</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>type of event - here
<strong>added</strong> or <strong>removed</strong></p></td></tr><tr><td
colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.instance.host</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>host name of the
instance</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>hazelcast.instance.port</code></p></td><td
colspan="1" rowspan="1"
class="confluenceTd"><p><code>Integer</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p>port number of the
instance</p></td></tr></tbody></table></div><div
class="confluence-information-macro confluence-information-macro-warning"><span
class="aui-icon aui-icon-small aui-iconf
ont-error confluence-information-macro-icon"></span><div
class="confluence-information-macro-body"><p>Header variables have changed in
Camel 2.8</p></div></div><div class="table-wrap"><table
class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p>Name</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Type</p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1"
rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastListenerTime</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>Long</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>time of the event in millis
<strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastListenerType</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1"
class="confluenceTd"><p>the map consumer sets here "instancelistener"
<strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastListenerActionn</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>type of event - here
<strong>added</strong> or <strong>removed</strong>. <strong><a shape="rect"
class="unresolved" href="#">Version 2.8</a></strong></p></td></tr><tr><td
colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastInstanceHost</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>String</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>host name of the instance
<strong><a shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>CamelHazelcastInstanc
ePort</code></p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p><code>Integer</code></p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p>port number of the instance <strong><a
shape="rect" class="unresolved" href="#">Version
2.8</a></strong></p></td></tr></tbody></table></div><h3
id="HazelcastComponent-Usinghazelcastreference"><span style="line-height:
1.5625;">Using hazelcast reference</span></h3><h4
id="HazelcastComponent-Byitsname">By its name</h4><div class="code panel pdl"
style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<pre class="brush: xml; gutter: false; theme: Default"
style="font-size:12px;"><bean id="hazelcastLifecycle"
class="com.hazelcast.core.LifecycleService"
- factory-bean="hazelcastInstance" factory-method="getLifecycleService"
- destroy-method="shutdown" />
+<script class="brush: xml; gutter: false; theme: Default"
type="syntaxhighlighter"><![CDATA[<bean id="hazelcastLifecycle"
class="com.hazelcast.core.LifecycleService"
+ factory-bean="hazelcastInstance"
factory-method="getLifecycleService"
+ destroy-method="shutdown" />
-<bean id="config" class="com.hazelcast.config.Config">
- <constructor-arg type="java.lang.String" value="HZ.INSTANCE" />
+<bean id="config"
class="com.hazelcast.config.Config">
+ <constructor-arg type="java.lang.String"
value="HZ.INSTANCE" />
</bean>
-<bean id="hazelcastInstance" class="com.hazelcast.core.Hazelcast"
factory-method="newHazelcastInstance">
- <constructor-arg type="com.hazelcast.config.Config" ref="config"/>
+<bean id="hazelcastInstance"
class="com.hazelcast.core.Hazelcast"
factory-method="newHazelcastInstance">
+ <constructor-arg type="com.hazelcast.config.Config"
ref="config"/>
</bean>
-<camelContext xmlns="http://camel.apache.org/schema/spring">
- <route id="testHazelcastInstanceBeanRefPut">
- <from uri="direct:testHazelcastInstanceBeanRefPut"/>
- <setHeader headerName="CamelHazelcastOperationType">
+<camelContext xmlns="http://camel.apache.org/schema/spring">
+ <route id="testHazelcastInstanceBeanRefPut">
+ <from uri="direct:testHazelcastInstanceBeanRefPut"/>
+ <setHeader headerName="CamelHazelcastOperationType">
<constant>put</constant>
</setHeader>
- <to
uri="hazelcast:map:testmap?hazelcastInstanceName=HZ.INSTANCE"/>
+ <to
uri="hazelcast:map:testmap?hazelcastInstanceName=HZ.INSTANCE"/>
</route>
- <route id="testHazelcastInstanceBeanRefGet">
- <from uri="direct:testHazelcastInstanceBeanRefGet" />
- <setHeader headerName="CamelHazelcastOperationType">
+ <route id="testHazelcastInstanceBeanRefGet">
+ <from uri="direct:testHazelcastInstanceBeanRefGet" />
+ <setHeader headerName="CamelHazelcastOperationType">
<constant>get</constant>
</setHeader>
- <to
uri="hazelcast:map:testmap?hazelcastInstanceName=HZ.INSTANCE"/>
- <to uri="seda:out" />
+ <to
uri="hazelcast:map:testmap?hazelcastInstanceName=HZ.INSTANCE"/>
+ <to uri="seda:out" />
</route>
-</camelContext></pre>
+</camelContext>]]></script>
</div></div><h4 id="HazelcastComponent-Byinstance">By instance</h4><div
class="code panel pdl" style="border-width: 1px;"><div class="codeContent
panelContent pdl">
[... 246 lines stripped ...]
