Author: buildbot
Date: Thu May 22 12:17:51 2014
New Revision: 909591
Log:
Production update by buildbot for camel
Modified:
websites/production/camel/content/cache/main.pageCache
websites/production/camel/content/mqtt.html
Modified: websites/production/camel/content/cache/main.pageCache
==============================================================================
Binary files - no diff available.
Modified: websites/production/camel/content/mqtt.html
==============================================================================
--- websites/production/camel/content/mqtt.html (original)
+++ websites/production/camel/content/mqtt.html Thu May 22 12:17:51 2014
@@ -86,62 +86,26 @@
<tbody>
<tr>
<td valign="top" width="100%">
-<div class="wiki-content maincontent"><h2 id="MQTT-MQTTComponent">MQTT
Component</h2>
-<p><strong>Available as of Camel 2.10</strong></p>
-
-<p>The <strong>mqtt:</strong> component is used for communicating with <a
shape="rect" class="external-link" href="http://mqtt.org";
rel="nofollow">MQTT</a> compliant message brokers, like <a shape="rect"
class="external-link" href="http://activemq.apache.org";>Apache ActiveMQ</a> or
<a shape="rect" class="external-link" href="http://mosquitto.org";
rel="nofollow">Mosquitto</a></p>
-
-<p>Camel will poll the feed every 60 seconds by default.<br clear="none">
-<strong>Note:</strong> The component currently only supports polling
(consuming) feeds.</p>
-
-<p>Maven users will need to add the following dependency to their
<code>pom.xml</code> for this component:</p>
-<div class="code panel pdl" style="border-width: 1px;"><div class="codeContent
panelContent pdl">
-<script class="theme: Default; brush: xml; gutter: false"
type="syntaxhighlighter"><![CDATA[
-<dependency>
+<div class="wiki-content maincontent"><h2 id="MQTT-MQTTComponent">MQTT
Component</h2><p><strong>Available as of Camel 2.10</strong></p><p>The
<strong>mqtt:</strong> component is used for communicating with <a shape="rect"
class="external-link" href="http://mqtt.org"; rel="nofollow">MQTT</a> compliant
message brokers, like <a shape="rect" class="external-link"
href="http://activemq.apache.org";>Apache ActiveMQ</a> or <a shape="rect"
class="external-link" href="http://mosquitto.org";
rel="nofollow">Mosquitto</a></p><p>Camel will poll the feed every 60 seconds by
default.<br clear="none"> <strong>Note:</strong> The component currently only
supports polling (consuming) feeds.</p><p>Maven users will need to add the
following dependency to their <code>pom.xml</code> for this component:</p><div
class="code panel pdl" style="border-width: 1px;"><div class="codeContent
panelContent pdl">
+<script class="theme: Default; brush: xml; gutter: false"
type="syntaxhighlighter"><![CDATA[<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-mqtt</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel core version -->
</dependency>
]]></script>
-</div></div>
-
-<h3 id="MQTT-URIformat">URI format</h3>
-
-<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[
-mqtt://name[?options]
+</div></div><h3 id="MQTT-URIformat">URI format</h3><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[mqtt://name[?options]
]]></script>
-</div></div>
-
-<p>Where <strong>name</strong> is the name you want to assign the
component.</p>
-
-<h3 id="MQTT-Options">Options</h3>
-<div class="confluenceTableSmall">
-<table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p> Property </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>host</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> <code>tcp://127.0.0.1:1883</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The URI of the
MQTT broker to connect too - this component also supports SSL - e.g.
<em>ssl://127.0.0.1:8883</em></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>localAddress</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The local InetAddress and port to use
</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>connectAttemptsMax</code> </p></td><td colspan="
1" rowspan="1" class="confluenceTd"><p> <code>-1</code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p> The maximum number of attempts
to establish an initial connection - <strong><em>-1</em></strong> in infinite.
</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>reconnectAttemptsMax</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>-1</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The maximum number of attempts to re-establish a
connection after failure - <strong><em>-1</em></strong> in infinite.
</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>reconnectDelay</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>10</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The time in milliseconds between attempts to
reestablish an initial or failed connection </p></td></tr><tr><td colspan="1"
rowspan="1" class="confluenceTd"><p> <code>r
econnectBackOffMultiplier</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>2.0</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The multiplier to use to the delay between connection
attempts for successive failed connection attempts </p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><p> <code>reconnectDelayMax</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>30000</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The maximum time in milliseconds between a new attempt
to establish a connection. So even using the reconnectBackOffMultiplier, this
property will define the maximum delay before another connection attempt to the
MQTT broker </p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>QoS</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>AtLeastOnce</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> The MQTT Q
uality of Service to use for message exchanges. It can be one of
<strong>AtMostOnce</strong>, <strong>AtLeastOnce</strong> or
<strong>ExactlyOnce</strong> </p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>subscribeTopicName</code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> The name of the Topic to subscribe to for
messages </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>publishTopicName</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code><em>camel/mqtt/test</em></code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p> The default Topic to publish
messages on </p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>byDefaultRetain</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> <code>false</code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p> The default
retain policy to be used on messages sent to the MQTT
broker</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>mqttTopicPropertyName</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>_MQTTTopicPropertyName+</code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p> The property name to look for
on an Exchange for an individual published message. If this is set - the name
will be used as the Topic to publish a message to the MQTT message broker.
</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>mqttRetainPropertyName</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>MQTTRetain</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> The property name to look for on an
Exchange for an individual published message. If this is set (expects a Boolean
value) - then the retain property will be set on the message sent to the MQTT
message broker. </p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><p>
<code>mqttQosPropertyName</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>MQTTQos</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> The property name to look for on an
Exchange for an individual published message. If this is set (one of
<strong>AtMostOnce</strong>, <strong>AtLeastOnce</strong> or
<strong>ExactlyOnce</strong> ) - then that QoS will be set on the message sent
to the MQTT message broker. </p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>connectWaitInSeconds</code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p> <code>10</code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p> Delay in seconds the Component
will wait for a connection to be established to the MQTT broker
</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>disconnectWaitInSeconds</code> </p></td><td colspan="1" rowspan="1"
class="con
fluenceTd"><p> <code>5</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p>the number of seconds the Component will wait for a
valid disconnect on stop() from the MQTT broker </p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><p> <code>sendWaitInSeconds</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>5</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The maximum time
the Component will wait for a receipt from the MQTT broker to acknowledge a
published message before throwing an exception</p></td></tr></tbody></table>
-</div>
-
-<p>You can append query options to the URI in the following format,
<code>?option=value&option=value&...</code></p>
-
-
-<h3 id="MQTT-Samples">Samples</h3>
-
-<p>Sending messages:</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[
-from("direct:foo").to("mqtt:cheese?publishTopicName=test.mqtt.topic");
+</div></div><p>Where <strong>name</strong> is the name you want to assign the
component.</p><h3 id="MQTT-Options">Options</h3><div
class="confluenceTableSmall">
+<table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1"
class="confluenceTh"><p> Property </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>host</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> <code>tcp://127.0.0.1:1883</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The URI of the
MQTT broker to connect too - this component also supports SSL - e.g.
<em>ssl://127.0.0.1:8883</em></p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>localAddress</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The local InetAddress and port to use
</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>connectAttemptsMax</code> </p></td><td colspan="
1" rowspan="1" class="confluenceTd"><p> <code>-1</code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p> The maximum number of attempts
to establish an initial connection - <strong><em>-1</em></strong> in infinite.
</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>reconnectAttemptsMax</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>-1</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The maximum number of attempts to re-establish a
connection after failure - <strong><em>-1</em></strong> in infinite.
</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>reconnectDelay</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>10</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The time in milliseconds between attempts to
reestablish an initial or failed connection </p></td></tr><tr><td colspan="1"
rowspan="1" class="confluenceTd"><p> <code>r
econnectBackOffMultiplier</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>2.0</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The multiplier to use to the delay between connection
attempts for successive failed connection attempts </p></td></tr><tr><td
colspan="1" rowspan="1" class="confluenceTd"><p> <code>reconnectDelayMax</code>
</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>30000</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The maximum time in milliseconds between a new attempt
to establish a connection. So even using the reconnectBackOffMultiplier, this
property will define the maximum delay before another connection attempt to the
MQTT broker </p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>qualityOfService</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> <code>AtLeastOnce</code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><
p> The MQTT Quality of Service to use for message exchanges. It can be one of
<strong>AtMostOnce</strong>, <strong>AtLeastOnce</strong> or
<strong>ExactlyOnce</strong> </p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>subscribeTopicName</code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> The name of the Topic to subscribe to for
messages </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>publishTopicName</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code><em>camel/mqtt/test</em></code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p> The default Topic to publish
messages on </p></td></tr><tr><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>byDefaultRetain</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p> <code>false</code> </p></td><td
colspan="1" rowspan="1" class="confluenceTd"><p
> The default retain policy to be used on messages sent to the MQTT
> broker</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
> <code>mqttTopicPropertyName</code> </p></td><td colspan="1" rowspan="1"
> class="confluenceTd"><p> <code>_MQTTTopicPropertyName+</code> </p></td><td
> colspan="1" rowspan="1" class="confluenceTd"><p> The property name to look
> for on an Exchange for an individual published message. If this is set - the
> name will be used as the Topic to publish a message to the MQTT message
> broker. </p></td></tr><tr><td colspan="1" rowspan="1"
> class="confluenceTd"><p> <code>mqttRetainPropertyName</code> </p></td><td
> colspan="1" rowspan="1" class="confluenceTd"><p> <code>MQTTRetain</code>
> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The property
> name to look for on an Exchange for an individual published message. If this
> is set (expects a Boolean value) - then the retain property will be set on
> the message sent to the MQTT message broker. </p></td
></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
><code>mqttQosPropertyName</code> </p></td><td colspan="1" rowspan="1"
>class="confluenceTd"><p> <code>MQTTQos</code> </p></td><td colspan="1"
>rowspan="1" class="confluenceTd"><p> The property name to look for on an
>Exchange for an individual published message. If this is set (one of
><strong>AtMostOnce</strong>, <strong>AtLeastOnce</strong> or
><strong>ExactlyOnce</strong> ) - then that QoS will be set on the message
>sent to the MQTT message broker. </p></td></tr><tr><td colspan="1"
>rowspan="1" class="confluenceTd"><p> <code>connectWaitInSeconds</code>
></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>10</code>
></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> Delay in
>seconds the Component will wait for a connection to be established to the
>MQTT broker </p></td></tr><tr><td colspan="1" rowspan="1"
>class="confluenceTd"><p> <code>disconnectWaitInSeconds</code> </p></td><td
>colspan="1" rowspan="
1" class="confluenceTd"><p> <code>5</code> </p></td><td colspan="1"
rowspan="1" class="confluenceTd"><p>the number of seconds the Component will
wait for a valid disconnect on stop() from the MQTT broker
</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>
<code>sendWaitInSeconds</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> <code>5</code> </p></td><td colspan="1" rowspan="1"
class="confluenceTd"><p> The maximum time the Component will wait for a receipt
from the MQTT broker to acknowledge a published message before throwing an
exception</p></td></tr></tbody></table>
+</div><p>You can append query options to the URI in the following format,
<code>?option=value&option=value&...</code></p><h3
id="MQTT-Samples">Samples</h3><p>Sending messages:</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[from("direct:foo").to("mqtt:cheese?publishTopicName=test.mqtt.topic");
]]></script>
-</div></div>
-
-<p>Consuming messages:</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[
-from("mqtt:bar?subscribeTopicName=test.mqtt.topic").transform(body().convertToString()).to("mock:result")
+</div></div><p>Consuming messages:</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[from("mqtt:bar?subscribeTopicName=test.mqtt.topic").transform(body().convertToString()).to("mock:result")
]]></script>
-</div></div>
-
-
-<h2 id="MQTT-Endpoints">Endpoints</h2>
+</div></div><p></p><h2 id="MQTT-Endpoints">Endpoints</h2>
<p></p><p>Camel supports the <a shape="rect"
href="message-endpoint.html">Message Endpoint</a> pattern using the <a
shape="rect" class="external-link"
href="http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/Endpoint.html";>Endpoint</a>
interface. Endpoints are usually created by a <a shape="rect"
href="component.html">Component</a> and Endpoints are usually referred to in
the <a shape="rect" href="dsl.html">DSL</a> via their <a shape="rect"
href="uris.html">URIs</a>. </p>
