MQTT connectAttemptsMax property does not appear to work

[whulse]

We have created a simple route from activeMQ to RabbitMQ using MQTT however
when camel starts up and the RabbitMQ broker is down, camel and activeMQ
shut down.

We have set the mqtt property connectAttemptsMax=-1 which should just retry
the connection, but this does not seem to work.

The following is the route config:

<route>
                
                <from
uri="activemq:topic://bmrsTopic?clientId=2&amp;durableSubscriptionName=mqtt"/>
                <to
uri=&quot;mqtt:bmrs?host=tcp://xx.xxx.xx.xx:1882&amp;amp;qualityOfService=AtLeastOnce&amp;amp;publishTopicName=logs&amp;amp;userName=&lt;username>&amp;password=<password>&amp;connectAttemptsMax=-1"/>
   
        </route>

and a snippet from the log file:

[INFO] 2016-04-21 10:31:13,827 org.apache.camel.component.mqtt.MQTTEndpoint
connect - Connecting to tcp://xx.xx.xx.xx:1882 using 10 seconds timeout
[DEBUG] 2016-04-21 10:31:23,784
org.apache.activemq.transport.AbstractInactivityMonitor run - WriteChecker:
10001ms elapsed since last write check.
[WARN] 2016-04-21 10:31:12,188
org.apache.camel.component.rabbitmq.RabbitMQProducer doStart - Failed to
create connection. It will attempt to connect again when publishing a
message.
java.net.ConnectException: Connection refused
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
        at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
        at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
        at java.net.Socket.connect(Socket.java:579)


Any suggestions would be appreciated





--
View this message in context: 
http://camel.465427.n5.nabble.com/MQTT-connectAttemptsMax-property-does-not-appear-to-work-tp5781649.html
Sent from the Camel - Users mailing list archive at Nabble.com.