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 <a shape="rect" href="components.html">Components</a> has their own implementation of <code>PollingConsumer</code> and therefore do not support the options above.</p><p>You can configure these options in endpoints <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("file:inbox?pollingConsumerQueueSize=50"); PollingConsumer consumer = endpoint.createPollingConsumer();