camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From build...@apache.org
Subject svn commit: r908352 - in /websites/production/camel/content: cache/main.pageCache polling-consumer.html
Date Thu, 08 May 2014 05:17:55 GMT
Author: buildbot
Date: Thu May  8 05:17:55 2014
New Revision: 908352

Log:
Production update by buildbot for camel

Modified:
    websites/production/camel/content/cache/main.pageCache
    websites/production/camel/content/polling-consumer.html

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

Modified: websites/production/camel/content/polling-consumer.html
==============================================================================
--- websites/production/camel/content/polling-consumer.html (original)
+++ websites/production/camel/content/polling-consumer.html Thu May  8 05:17:55 2014
@@ -92,7 +92,7 @@ PollingConsumer consumer = endpoint.crea
 Exchange exchange = consumer.receive();
 ]]></script>
 </div></div><p>The <code>ConsumerTemplate</code> (discussed
below) is also available.</p><p>There are 3 main polling methods on <a shape="rect"
class="external-link" href="http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/PollingConsumer.html">PollingConsumer</a></p><div
class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1"
rowspan="1" class="confluenceTh"><p>Method name</p></th><th colspan="1"
rowspan="1" class="confluenceTh"><p>Description</p></th></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><p><a shape="rect" class="external-link"
href="http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/PollingConsumer.html#receive()">receive()</a></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>Waits until a message is available
and then returns it; potentially blocking forever</p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><p><a shape="rect" class="external-link"
href="http://camel.
 apache.org/maven/current/camel-core/apidocs/org/apache/camel/PollingConsumer.html#receive(long)">receive(long)</a></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>Attempts to receive a message exchange,
waiting up to the given timeout and returning null if no message exchange could be received
within the time available</p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p><a shape="rect" class="external-link" href="http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/PollingConsumer.html#receiveNoWait()">receiveNoWait()</a></p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p>Attempts to receive a message exchange
immediately without waiting and returning null if a message exchange is not available yet</p></td></tr></tbody></table></div><h3
id="PollingConsumer-EventDrivenPollingConsumerOptions">EventDrivenPollingConsumer Options</h3><p>The
EventDrivePollingConsumer (the default implementation) supports the following options:</p>
 <div class="confluenceTableSmall">
-<table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p> Option </p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p> Default </p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p> Description </p></th></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><p> <code>pollingConsumerQueueSize</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>1000</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <strong>Camel
2.14/2.13.1:</strong> The queue size for the internal handoff queue between the polling
consumer, and producers sending data into the queue. </p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><p> <code>pollingConsumerBlockWhenFull</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>true</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <strong>Camel
2.14/2.13.1:</strong> Whether to block any producer if the internal queue is
  full. </p></td></tr></tbody></table>
+<table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p> Option </p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p> Default </p></th><th colspan="1" rowspan="1"
class="confluenceTh"><p> Description </p></th></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><p> <code>pollingConsumerQueueSize</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>1000</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <strong>Camel
2.14/2.13.1/2.12.4:</strong> The queue size for the internal handoff queue between the
polling consumer, and producers sending data into the queue. </p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><p> <code>pollingConsumerBlockWhenFull</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>true</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <strong>Camel
2.14/2.13.1/2.12/4:</strong> Whether to block any producer if the int
 ernal queue is full. </p></td></tr></tbody></table>
 </div><p>Notice that some Camel&#160;<a shape="rect" href="components.html">Components</a>&#160;has
their own implementation of&#160;<code>PollingConsumer</code> and therefore
do not support the options above.</p><p>You can configure these options in endpoints&#160;<a
shape="rect" href="uris.html">URIs</a>, such as shown below:</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[Endpoint
endpoint = context.getEndpoint(&quot;file:inbox?pollingConsumerQueueSize=50&quot;);
 PollingConsumer consumer = endpoint.createPollingConsumer();



Mime
View raw message