camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From build...@apache.org
Subject 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
Date Tue, 17 Jul 2012 06:20:21 GMT
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>



Mime
View raw message