camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From build...@apache.org
Subject svn commit: r893199 - in /websites/production/camel/content: cache/main.pageCache jgroups.html
Date Tue, 07 Jan 2014 21:18:55 GMT
Author: buildbot
Date: Tue Jan  7 21:18:55 2014
New Revision: 893199

Log:
Production update by buildbot for camel

Modified:
    websites/production/camel/content/cache/main.pageCache
    websites/production/camel/content/jgroups.html

Modified: websites/production/camel/content/cache/main.pageCache
==============================================================================
Binary files - no diff available.

Modified: websites/production/camel/content/jgroups.html
==============================================================================
--- websites/production/camel/content/jgroups.html (original)
+++ websites/production/camel/content/jgroups.html Tue Jan  7 21:18:55 2014
@@ -111,7 +111,7 @@
 </div></div><h3 id="JGroups-URIformat">URI format</h3><div class="code
panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
 <script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[jgroups:clusterName[?options]
 ]]></script>
-</div></div><p>Where <strong>clusterName</strong> represents
the name of the JGroups cluster the component should connect to.</p><h3 id="JGroups-Options">Options</h3><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>channelProperties</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>null</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><strong>Camel 2.10.0:</strong>
Specifies configuration properties of the <a shape="rect" class="external-link" href="http://www.jgroups.org/javadoc/org/jgroups/JChannel.html"
rel="nofollow">JChannel </a> used by the endpoint.</p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><code>enableViewMessages</code><
 /td><td colspan="1" rowspan="1" class="confluenceTd"><code>false</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><strong>Camel 2.13.0</strong>:&#160;
Consumer only. If set to <code>true</code>, the consumer endpoint will receive
<code>org.jgroups.View</code> messages as well (not only <code>org.jgroups.Message</code>
instances). By default only regular messages are consumed by the endpoint.</td></tr></tbody></table></div><h3
id="JGroups-Headers">Headers</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th
colspan="1" rowspan="1" class="confluenceTh">Header</th><th colspan="1" rowspan="1"
class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Since
version</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><code>JGROUPS_ORIGINAL_MESSAGE</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><code>JGroupsEndpoint.HEADER_JGROUPS_ORIGINAL_MESSAGE<
 /code></td><td colspan="1" rowspan="1" class="confluenceTd"><strong>2.13.0</strong></td><td
colspan="1" rowspan="1" class="confluenceTd">The original <code>org.jgroups.Message</code>
instance from which the body of the consumed message has been extracted.</td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><code>JGROUPS_SRC</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><code><code>JGroupsEndpoint.</code>HEADER_JGROUPS_SRC</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><strong>2.10.0</strong></td><td
colspan="1" rowspan="1" class="confluenceTd">The <code>org.jgroups.Address</code>
instance extracted by <code>org.jgroups.Message</code>.getSrc() method of the
consumed message.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>JGROUPS_DEST</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><code><code>JGroupsEndpoint.</code>HEADER_JGROUPS_DEST</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><strong>2.10.0</stron
 g></td><td colspan="1" rowspan="1" class="confluenceTd">The <code>org.jgroups.Address</code>
instance extracted by <code>org.jgroups.Message</code>.getDest() method of the
consumed message.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><code>JGROUPS_CHANNEL_ADDRESS</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><code><code>JGroupsEndpoint.</code>HEADER_JGROUPS_CHANNEL_ADDRESS</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><strong>2.13.0</strong></td><td
colspan="1" rowspan="1" class="confluenceTd">Address (<code>org.jgroups.Address</code>)
of the channel associated with the endpoint.</td></tr></tbody></table></div><p>&#160;</p><h3
id="JGroups-Usage">Usage</h3><p>Using <code>jgroups</code> component
on the consumer side of the route will capture messages received by the <code>JChannel</code>
associated with the endpoint and forward them to the Camel route. JGroups consumer processes
incoming messages <a shape="rect" class="external-link" href
 ="http://camel.apache.org/asynchronous-routing-engine.html">asynchronously</a>.</p><div
class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent
pdl">
+</div></div><p>Where <strong>clusterName</strong> represents
the name of the JGroups cluster the component should connect to.</p><h3 id="JGroups-Options">Options</h3><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>channelProperties</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><code>null</code></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><strong>Camel 2.10.0:</strong>
Specifies configuration properties of the <a shape="rect" class="external-link" href="http://www.jgroups.org/javadoc/org/jgroups/JChannel.html"
rel="nofollow">JChannel </a> used by the endpoint.</p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><code>enableViewMessages</code><
 /td><td colspan="1" rowspan="1" class="confluenceTd"><code>false</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><strong>Camel 2.13.0</strong>:&#160;
Consumer only. If set to <code>true</code>, the consumer endpoint will receive
<code>org.jgroups.View</code> messages as well (not only <code>org.jgroups.Message</code>
instances). By default only regular messages are consumed by the endpoint.</td></tr></tbody></table></div><h3
id="JGroups-Headers">Headers</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th
colspan="1" rowspan="1" class="confluenceTh">Header</th><th colspan="1" rowspan="1"
class="confluenceTh">Constant</th><th colspan="1" rowspan="1" class="confluenceTh">Since
version</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><code>JGROUPS_ORIGINAL_MESSAGE</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><code>JGroupsEndpoint.HEADER_JGROUPS_ORIGINAL_MESSAGE<
 /code></td><td colspan="1" rowspan="1" class="confluenceTd"><strong>2.13.0</strong></td><td
colspan="1" rowspan="1" class="confluenceTd">The original <code>org.jgroups.Message</code>
instance from which the body of the consumed message has been extracted.</td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><code>JGROUPS_SRC</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><code><code>JGroupsEndpoint.</code>HEADER_JGROUPS_SRC</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><strong>2.10.0</strong></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><strong>Consume</strong>r:
The <code>org.jgroups.Address</code> instance extracted by <code>org.jgroups.Message</code>.getSrc()
method of the consumed message.</p><p><strong>Producer</strong>: The
custom source <code>org.jgroups.Address</code> of the message to be sent.</p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><code>JGROUPS_DEST</code></td><td
colspan="1" rowspan="1" class="confl
 uenceTd"><code><code>JGroupsEndpoint.</code>HEADER_JGROUPS_DEST</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><strong>2.10.0</strong></td><td
colspan="1" rowspan="1" class="confluenceTd"><p><strong>Consumer</strong>:
The <code>org.jgroups.Address</code> instance extracted by <code>org.jgroups.Message</code>.getDest()
method of the consumed message.</p><p><strong>Producer</strong>: The
custom destination <code>org.jgroups.Address</code> of the message to be sent.</p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><code>JGROUPS_CHANNEL_ADDRESS</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><code><code>JGroupsEndpoint.</code>HEADER_JGROUPS_CHANNEL_ADDRESS</code></td><td
colspan="1" rowspan="1" class="confluenceTd"><strong>2.13.0</strong></td><td
colspan="1" rowspan="1" class="confluenceTd">Address (<code>org.jgroups.Address</code>)
of the channel associated with the endpoint.</td></tr></tbody></table></div><p>&#160;</p><h3
id="JGroups-Usage">Us
 age</h3><p>Using <code>jgroups</code> component on the consumer side
of the route will capture messages received by the <code>JChannel</code> associated
with the endpoint and forward them to the Camel route. JGroups consumer processes incoming
messages <a shape="rect" class="external-link" href="http://camel.apache.org/asynchronous-routing-engine.html">asynchronously</a>.</p><div
class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent
pdl">
 <script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[//
Capture messages from cluster named
 // &#39;clusterName&#39; and send them to Camel route.
 from(&quot;jgroups:clusterName&quot;).to(&quot;seda:queue&quot;);
@@ -127,11 +127,33 @@ from(&quot;jgroups:clusterName?enableVie
   filter(dropNonCoordinatorViews()).
   to(&quot;seda:masterNodeEventsQueue&quot;);
 ]]></script>
+</div></div><h3 id="JGroups-Predefinedexpressions">Predefined expressions</h3><p>JGroups
component comes with predefined expressions factory class named <code>JGroupsExpressions.</code></p><p>If
you would like to create <a shape="rect" href="delayer.html">delayer</a> that
would affect the route only if the Camel context has not been started yet, use the <code>JGroupsExpressions.delayIfContextNotStarted(long
delay)</code> factory method. The expression created by this factory method will return
given delay value only if the Camel context is in the state different than <code>started</code>.
This expression is particularly useful if you would like to use JGroups component for keeping
singleton (master) route within the cluster. <a shape="rect" href="controlbus-component.html">Control
Bus</a> <code>start</code> command won't initialize the singleton route
if the Camel Context hasn't been yet started. So you need to delay a startup of the master
route, to be sure that it has been initial
 ized after the Camel Context startup. Because such scenario can happen only during the initialization
of the cluster, we don't want to delay startup of the slave node becoming the new master -
that's why we need a conditional delay expression.</p><p>The snippet below demonstrates
how to use conditional delaying with the JGroups component to delay the initial startup of
master node in the cluster.</p><div class="code panel pdl" style="border-width: 1px;"><div
class="codeContent panelContent pdl">
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[import
static java.util.concurrent.TimeUnit.SECONDS;
+import static org.apache.camel.component.jgroups.JGroupsExpressions.delayIfContextNotStarted;
+import static org.apache.camel.component.jgroups.JGroupsFilters.dropNonCoordinatorViews;
+...
+from(&quot;jgroups:clusterName?enableViewMessages=true&quot;).
+  filter(dropNonCoordinatorViews()).
+  threads().delay(delayIfContextNotStarted(SECONDS.toMillis(5))). // run in separated and
delayed thread. Delay only if the context hasn&#39;t been started already. 
+  to(&quot;controlbus:route?routeId=masterRoute&amp;action=start&amp;async=true&quot;);
+
+from(&quot;timer://master?repeatCount=1&quot;).routeId(&quot;masterRoute&quot;).autoStartup(false).to(masterMockUri); ]]></script>
 </div></div><h3 id="JGroups-Examples">Examples</h3><h4 id="JGroups-Receiveclusterviewchangenotifications">Receive
cluster view change notifications</h4><p>The snippet below demonstrates how to
create the consumer endpoint listening to the&#160;notifications regarding cluster membership
changes. By default only regular messages are consumed by the endpoint.</p><div class="code
panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
 <script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[mockEndpoint.setExpectedMessageCount(1);
 mockEndpoint.message(0).body().isInstanceOf(org.jgroups.View.class);
 from(&quot;jgroups:clusterName?enableViewMessages=true&quot;).to(mockEndpoint);
 mockEndpoint.assertIsSatisfied();]]></script>
+</div></div><h4 id="JGroups-Keepingsingletonroutewithinthecluster">Keeping
singleton route within the cluster</h4><p>The snippet below demonstrates how to
keep the singleton consumer route in the cluster of Camel Contexts. As soon as the master
node dies, one of the slaves will be elected as a new master and started. In this particular
example we want to keep singleton <a shape="rect" href="jetty.html">jetty</a>
instance listening for the requests on address<code> <span class="nolink">http://localhost:8080/orders</span></code>.</p><div
class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent
pdl">
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[import
static java.util.concurrent.TimeUnit.SECONDS;
+import static org.apache.camel.component.jgroups.JGroupsExpressions.delayIfContextNotStarted;
+import static org.apache.camel.component.jgroups.JGroupsFilters.dropNonCoordinatorViews;
+...
+from(&quot;jgroups:clusterName?enableViewMessages=true&quot;).
+  filter(dropNonCoordinatorViews()).
+  threads().delay(delayIfContextNotStarted(SECONDS.toMillis(5))). // run in separated and
delayed thread. Delay only if the context hasn&#39;t been started already. 
+  to(&quot;controlbus:route?routeId=masterRoute&amp;action=start&amp;async=true&quot;);
+
+from(&quot;jetty:http://localhost:8080/orders&quot;).routeId(&quot;masterRoute&quot;).autoStartup(false).to(&quot;jms:orders&quot;); ]]></script>
 </div></div></div>
         </td>
         <td valign="top">



Mime
View raw message