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 2016/06/10 16:18:56 UTC
svn commit: r990322 - in /websites/production/camel/content:
cache/main.pageCache ironmq.html
Author: buildbot
Date: Fri Jun 10 16:18:56 2016
New Revision: 990322
Log:
Production update by buildbot for camel
Modified:
websites/production/camel/content/cache/main.pageCache
websites/production/camel/content/ironmq.html
Modified: websites/production/camel/content/cache/main.pageCache
==============================================================================
Binary files - no diff available.
Modified: websites/production/camel/content/ironmq.html
==============================================================================
--- websites/production/camel/content/ironmq.html (original)
+++ websites/production/camel/content/ironmq.html Fri Jun 10 16:18:56 2016
@@ -97,7 +97,7 @@
<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[ironmq:queueName[?options]
]]></script>
</div></div><p>Where <strong>queueName</strong> identifies the IronMQ queue you want to publish or consume messages from.</p><h3 id="IronMQ-Options">Options</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Name</th><th colspan="1" rowspan="1" class="confluenceTh">Group</th><th colspan="1" rowspan="1" class="confluenceTh">Default</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><strong>client</strong></td><td colspan="1" rowspan="1" class="confluenceTd">common</td><td colspan="1" rowspan="1" class="confluenceTd">null</td><td colspan="1" rowspan="1" class="confluenceTd">io.iron.ironmq.Client</td><td colspan="1" rowspan="1" class="confluenceTd"><span>Reference to a io.iron.ironmq.Client in the Registry.</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><strong>iron
MQCloud</strong></td><td colspan="1" rowspan="1" class="confluenceTd">common</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><a shape="rect" class="external-link" href="https://mq-aws-us-east-1-1.iron.io" rel="nofollow">https://mq-aws-us-east-1-1.iron.io</a></p></td><td colspan="1" rowspan="1" class="confluenceTd">String</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1">IronMq Cloud <span class="s1">url</span>. <span class="s1">Urls</span> for public clusters: https://<span class="s1">mq</span>-<span class="s1">aws</span>-<a shape="rect" class="external-link" href="http://us-east-1-1.iron.io" rel="nofollow">us-east-1-1.iron.io</a> (US), https://<span class="s1">mq</span>-<span class="s1">aws</span>-<span class="s1">eu</span>-<a shape="rect" class="external-link" href="http://west-1-1.iron.io" rel="nofollow">west-1-1.iron.io</a> (EU)</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><strong>preserveHeaders</strong></td><td colspan="
1" rowspan="1" class="confluenceTd">common</td><td colspan="1" rowspan="1" class="confluenceTd">false</td><td colspan="1" rowspan="1" class="confluenceTd">boolean</td><td colspan="1" rowspan="1" class="confluenceTd"><p><span>Should message headers be preserved when publishing messages.</span></p><p>This will add the Camel headers to the Iron MQ message as a json payload with a header list, and a message body.</p><p>Useful when Camel is both consumer and producer.</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><strong>projectId</strong></td><td colspan="1" rowspan="1" class="confluenceTd">common</td><td colspan="1" rowspan="1" class="confluenceTd">null</td><td colspan="1" rowspan="1" class="confluenceTd">String</td><td colspan="1" rowspan="1" class="confluenceTd"><span>The IronMQ project Id</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><strong>token</strong></td><td colspan="1" rowspan="1" class="confluenceTd">common</td><td colspan="1" rowsp
an="1" class="confluenceTd">null</td><td colspan="1" rowspan="1" class="confluenceTd">String</td><td colspan="1" rowspan="1" class="confluenceTd">The I<span>ronMQ token</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><strong>batchDelete</strong></td><td colspan="1" rowspan="1" class="confluenceTd">consumer</td><td colspan="1" rowspan="1" class="confluenceTd">false</td><td colspan="1" rowspan="1" class="confluenceTd">boolean</td><td colspan="1" rowspan="1" class="confluenceTd"><span>Should messages be deleted in one batch. This will limit the number of api requests since messages are deleted in one request, instead of one pr. exchange. If enabled care should be taken that the consumer is idempotent when processing exchanges.</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><strong>concurrentConsumers</strong></td><td colspan="1" rowspan="1" class="confluenceTd">consumer</td><td colspan="1" rowspan="1" class="confluenceTd">1</td><td colspan="1"
rowspan="1" class="confluenceTd">int</td><td colspan="1" rowspan="1" class="confluenceTd"><span>The number of concurrent consumers.</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><strong>maxMessagesPerPoll</strong></td><td colspan="1" rowspan="1" class="confluenceTd">consumer</td><td colspan="1" rowspan="1" class="confluenceTd">1</td><td colspan="1" rowspan="1" class="confluenceTd">int</td><td colspan="1" rowspan="1" class="confluenceTd"><span>Number of messages to poll pr. call. <span style="color: rgb(54,54,54);">Maximum is 100.</span></span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><strong>timeout</strong></td><td colspan="1" rowspan="1" class="confluenceTd">consumer</td><td colspan="1" rowspan="1" class="confluenceTd">60</td><td colspan="1" rowspan="1" class="confluenceTd">int</td><td colspan="1" rowspan="1" class="confluenceTd"><span>After timeout (in seconds), item will be placed back onto the queue.</span></td></tr><tr><td colspan="
1" rowspan="1" class="confluenceTd"><strong>wait</strong></td><td colspan="1" rowspan="1" class="confluenceTd">consumer</td><td colspan="1" rowspan="1" class="confluenceTd">0</td><td colspan="1" rowspan="1" class="confluenceTd">int</td><td colspan="1" rowspan="1" class="confluenceTd"><span>Time in seconds to wait for a message to become available. This enables long polling. Default is 0 (does not wait), maximum is 30.</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><strong>visibilityDelay</strong></td><td colspan="1" rowspan="1" class="confluenceTd">producer</td><td colspan="1" rowspan="1" class="confluenceTd">0</td><td colspan="1" rowspan="1" class="confluenceTd">int</td><td colspan="1" rowspan="1" class="confluenceTd"><span>The item will not be available on the queue until this many seconds have passed. Default is 0 seconds.</span></td></tr></tbody></table></div><h3 id="IronMQ-Producerheaders">Producer headers</h3><div class="table-wrap"><table class="confluen
ceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Header</th><th colspan="1" rowspan="1" class="confluenceTh">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><span>CamelIronMQOperation</span></td><td colspan="1" rowspan="1" class="confluenceTd">String</td><td colspan="1" rowspan="1" class="confluenceTd"><span>If value set to </span><em>CamelIronMQClearQueue </em><span>the queue is cleared of unconsumed messages.</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><span>CamelIronMQMessageId</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span>String or io.iron.ironmq.Ids</span></td><td colspan="1" rowspan="1" class="confluenceTd"><span>The id of the IronMQ message as a String when sending a single message, or a Ids object when sending a array of strings. See message body</span></td></tr></tbody></table></div><h3 id="IronMQ-Consumerheaders">Consumer head
ers</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">Type</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><span>CamelIronMQMessageId</span></td><td colspan="1" rowspan="1" class="confluenceTd">String</td><td colspan="1" rowspan="1" class="confluenceTd"><span>The id of the message.</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><span>CamelIronMQReservationId</span></td><td colspan="1" rowspan="1" class="confluenceTd">String</td><td colspan="1" rowspan="1" class="confluenceTd"><span>The reservation id of the message.</span></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><span>CamelIronMQReservedCount</span></td><td colspan="1" rowspan="1" class="confluenceTd">String</td><td colspan="1" rowspan="1" class="confluenceTd"><span>The number of times
this message has been reserved.</span></td></tr></tbody></table></div><h3 id="IronMQ-Messagebodywhenproducing">Message body when producing</h3><p>Should be either a String or a array of Strings.</p><p>In the latter case the batch of strings will be send to IronMQ as one request, creating one message pr. element in the array.</p><h3 id="IronMQ-Consumerexample">Consumer example</h3><p>Consume 50 messages pr. poll from the queue 'testqueue' on aws eu, and save the messages to files.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[from("ironmq:testqueue?ironMQCloud=mq-aws-eu-west-1.iron.io&projectId=myIronMQProjectid&token=myIronMQToken&maxMessagesPerPoll=50")
+<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[from("ironmq:testqueue?ironMQCloud=https://mq-aws-eu-west-1-1.iron.io&projectId=myIronMQProjectid&token=myIronMQToken&maxMessagesPerPoll=50")
.to("file:somefolder");]]></script>
</div></div><h3 id="IronMQ-Producerexample">Producer example</h3><p>Dequeue from activemq jms and enqueue the messages on IronMQ.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[from("activemq:foo")