You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bu...@apache.org on 2012/07/17 08:20:21 UTC
svn commit: r826091 - in /websites/production/camel/content:
book-in-one-page.html book-pattern-appendix.html cache/main.pageCache
camel-2110-release.html resequencer.html
Author: buildbot
Date: Tue Jul 17 06:20:20 2012
New Revision: 826091
Log:
Production update by buildbot for camel
Modified:
websites/production/camel/content/book-in-one-page.html
websites/production/camel/content/book-pattern-appendix.html
websites/production/camel/content/cache/main.pageCache
websites/production/camel/content/camel-2110-release.html
websites/production/camel/content/resequencer.html
Modified: websites/production/camel/content/book-in-one-page.html
==============================================================================
--- websites/production/camel/content/book-in-one-page.html (original)
+++ websites/production/camel/content/book-in-one-page.html Tue Jul 17 06:20:20 2012
@@ -16928,6 +16928,22 @@ resequencer(header(<span class="code-quo
<p>This option is available for both batch and stream resequencer.</p>
+<h4><a shape="rect" name="BookInOnePage-RejectOldExchanges"></a>Reject Old Exchanges</h4>
+<p><b>Available as of Camel 2.11</b></p>
+
+<p>This option can be used to prevent out of order messages from being sent regardless of the event that delivered messages downstream (capacity, timeout, etc). If enabled using <tt>rejectOld()</tt>, the <a shape="rect" href="resequencer.html" title="Resequencer">Resequencer</a> will throw a <tt>MessageRejectedException</tt> when an incoming <a shape="rect" href="exchange.html" title="Exchange">Exchange</a> is "older" (based on the Comparator) than the last delivered message. This provides an extra level of control with regards to delayed message ordering. </p>
+
+<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
+<pre class="code-java">
+from(<span class="code-quote">"direct:start"</span>)
+ .onException(MessageRejectedException.class).handled(<span class="code-keyword">true</span>).to(<span class="code-quote">"mock:error"</span>).end()
+ .resequence(header(<span class="code-quote">"seqno"</span>)).stream().timeout(1000).rejectOld()
+ .to(<span class="code-quote">"mock:result"</span>);
+</pre>
+</div></div>
+
+<p>This option is available for the stream resequencer only.</p>
+
<h3><a shape="rect" name="BookInOnePage-StreamResequencing"></a>Stream Resequencing</h3>
<p>The next example shows how to use the stream-processing resequencer. Messages are re-ordered based on their sequence numbers given by a <tt>seqnum</tt> header using gap detection and timeouts on the level of individual messages. </p>
Modified: websites/production/camel/content/book-pattern-appendix.html
==============================================================================
--- websites/production/camel/content/book-pattern-appendix.html (original)
+++ websites/production/camel/content/book-pattern-appendix.html Tue Jul 17 06:20:20 2012
@@ -2664,6 +2664,22 @@ resequencer(header(<span class="code-quo
<p>This option is available for both batch and stream resequencer.</p>
+<h4><a shape="rect" name="BookPatternAppendix-RejectOldExchanges"></a>Reject Old Exchanges</h4>
+<p><b>Available as of Camel 2.11</b></p>
+
+<p>This option can be used to prevent out of order messages from being sent regardless of the event that delivered messages downstream (capacity, timeout, etc). If enabled using <tt>rejectOld()</tt>, the <a shape="rect" href="resequencer.html" title="Resequencer">Resequencer</a> will throw a <tt>MessageRejectedException</tt> when an incoming <a shape="rect" href="exchange.html" title="Exchange">Exchange</a> is "older" (based on the Comparator) than the last delivered message. This provides an extra level of control with regards to delayed message ordering. </p>
+
+<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
+<pre class="code-java">
+from(<span class="code-quote">"direct:start"</span>)
+ .onException(MessageRejectedException.class).handled(<span class="code-keyword">true</span>).to(<span class="code-quote">"mock:error"</span>).end()
+ .resequence(header(<span class="code-quote">"seqno"</span>)).stream().timeout(1000).rejectOld()
+ .to(<span class="code-quote">"mock:result"</span>);
+</pre>
+</div></div>
+
+<p>This option is available for the stream resequencer only.</p>
+
<h3><a shape="rect" name="BookPatternAppendix-StreamResequencing"></a>Stream Resequencing</h3>
<p>The next example shows how to use the stream-processing resequencer. Messages are re-ordered based on their sequence numbers given by a <tt>seqnum</tt> header using gap detection and timeouts on the level of individual messages. </p>
Modified: websites/production/camel/content/cache/main.pageCache
==============================================================================
Binary files - no diff available.
Modified: websites/production/camel/content/camel-2110-release.html
==============================================================================
--- websites/production/camel/content/camel-2110-release.html (original)
+++ websites/production/camel/content/camel-2110-release.html Tue Jul 17 06:20:20 2012
@@ -84,7 +84,7 @@
<p>Welcome to the 2.11.0 release with approximately XXX issues resolved - including new features, improvements, and bug fixes, such as: </p>
-<ul><li>Added support for SOAP 1.2 in <a shape="rect" href="soap.html" title="SOAP">SOAP</a> data format.</li><li><a shape="rect" href="cache.html" title="Cache">Cache</a> operation for add/update now supports expiry headers to control time to live/idle/eternal.</li><li>Added <tt>allowNullBody</tt> option to <a shape="rect" href="jms.html" title="JMS">JMS</a> to configure whether sending messages with no body is allowed.</li><li>Added <tt>connectOnStartup</tt> option to <a shape="rect" href="hdfs.html" title="HDFS">HDFS</a> to allow to connect on demand, to avoid having Hadoop block for long time connecting to the HDFS cluster, as it has a hardcoded 15 minute retry mechanism.</li><li>Added support for daily and weekly trends to <a shape="rect" href="twitter.html" title="Twitter">Twitter</a> component.</li><li>The <a shape="rect" href="camel-maven-archetypes.html" title="Camel Maven Archetypes">Camel Maven Archetypes</a> now generates projects without any license headers.</li
></ul>
+<ul><li>Added support for SOAP 1.2 in <a shape="rect" href="soap.html" title="SOAP">SOAP</a> data format.</li><li><a shape="rect" href="cache.html" title="Cache">Cache</a> operation for add/update now supports expiry headers to control time to live/idle/eternal.</li><li>Added <tt>allowNullBody</tt> option to <a shape="rect" href="jms.html" title="JMS">JMS</a> to configure whether sending messages with no body is allowed.</li><li>Added <tt>connectOnStartup</tt> option to <a shape="rect" href="hdfs.html" title="HDFS">HDFS</a> to allow to connect on demand, to avoid having Hadoop block for long time connecting to the HDFS cluster, as it has a hardcoded 15 minute retry mechanism.</li><li>Added support for daily and weekly trends to <a shape="rect" href="twitter.html" title="Twitter">Twitter</a> component.</li><li>The <a shape="rect" href="camel-maven-archetypes.html" title="Camel Maven Archetypes">Camel Maven Archetypes</a> now generates projects without any license headers.</li
><li>Added 'rejectOld' option to the <a shape="rect" href="resequencer.html" title="Resequencer">Resequencer</a> to prevent out of order messages from being delivered after capacity/timeout events occur</li></ul>
<h3><a shape="rect" name="Camel2.11.0Release-Fixedissues"></a>Fixed issues</h3>
@@ -92,7 +92,6 @@
<ul><li>Fixed <a shape="rect" href="routepolicy.html" title="RoutePolicy">RoutePolicy</a> used from Spring XML with <tt>routePolicyRef</tt> may not invoke all callbacks on the policy.</li><li>Fixed <a shape="rect" href="mina.html" title="MINA">MINA</a> consumer to force disconnect upon timeout when doing request/reply, as late replies may cause side effects otherwise.</li><li>Fixed <a shape="rect" href="simple.html" title="Simple">Simple</a> language with empty quoted literals in predicates, so you can compare against empty strings.</li><li>Fixed <a shape="rect" href="soap.html" title="SOAP">SOAP</a> data format to set SOAP 1.1 namespace when marhsalling faults.</li><li>Fixed <a shape="rect" href="seda.html" title="SEDA">SEDA</a> producer to send to the right BlockingQueue being attached on the <a shape="rect" href="seda.html" title="SEDA">SEDA</a> endpoint so that the sent messages don't get lost.</li><li>Fixed using <tt>sendEmptyMessageWhenIdle=true</tt> on a batch consume
r such as <a shape="rect" href="file2.html" title="File2">File</a> now working with <a shape="rect" href="aggregator2.html" title="Aggregator2">Aggregate</a> EIP when using <tt>completionFromBatchConsumer</tt></li></ul>
-
<h3><a shape="rect" name="Camel2.11.0Release-NewEnterpriseIntegrationPatterns"></a>New <a shape="rect" href="enterprise-integration-patterns.html" title="Enterprise Integration Patterns">Enterprise Integration Patterns</a></h3>
<h3><a shape="rect" name="Camel2.11.0Release-NewCamelKarafCommand"></a>New Camel Karaf Command</h3>
Modified: websites/production/camel/content/resequencer.html
==============================================================================
--- websites/production/camel/content/resequencer.html (original)
+++ websites/production/camel/content/resequencer.html Tue Jul 17 06:20:20 2012
@@ -212,6 +212,22 @@ resequencer(header(<span class="code-quo
<p>This option is available for both batch and stream resequencer.</p>
+<h4><a shape="rect" name="Resequencer-RejectOldExchanges"></a>Reject Old Exchanges</h4>
+<p><b>Available as of Camel 2.11</b></p>
+
+<p>This option can be used to prevent out of order messages from being sent regardless of the event that delivered messages downstream (capacity, timeout, etc). If enabled using <tt>rejectOld()</tt>, the <a shape="rect" href="resequencer.html" title="Resequencer">Resequencer</a> will throw a <tt>MessageRejectedException</tt> when an incoming <a shape="rect" href="exchange.html" title="Exchange">Exchange</a> is "older" (based on the Comparator) than the last delivered message. This provides an extra level of control with regards to delayed message ordering. </p>
+
+<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
+<pre class="code-java">
+from(<span class="code-quote">"direct:start"</span>)
+ .onException(MessageRejectedException.class).handled(<span class="code-keyword">true</span>).to(<span class="code-quote">"mock:error"</span>).end()
+ .resequence(header(<span class="code-quote">"seqno"</span>)).stream().timeout(1000).rejectOld()
+ .to(<span class="code-quote">"mock:result"</span>);
+</pre>
+</div></div>
+
+<p>This option is available for the stream resequencer only.</p>
+
<h3><a shape="rect" name="Resequencer-StreamResequencing"></a>Stream Resequencing</h3>
<p>The next example shows how to use the stream-processing resequencer. Messages are re-ordered based on their sequence numbers given by a <tt>seqnum</tt> header using gap detection and timeouts on the level of individual messages. </p>