camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From whulse <wi...@me.com>
Subject Re: MQTT connectAttemptsMax property does not appear to work
Date Tue, 26 Apr 2016 10:30:47 GMT
The following is the log file for MQTT with a single connection attempt and
subsequent shut down.

[DEBUG] 2016-04-26 09:56:22,838
org.apache.camel.impl.DefaultComponentResolver resolveComponent - Found
component: mqtt via type: org.apache.camel.component.mqtt.MQTTComponent via:
META-INF/services/org/apache/camel/component/mqtt
[DEBUG] 2016-04-26 09:56:22,936
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer -
Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=components,name="mqtt"
[DEBUG] 2016-04-26 09:56:22,980 org.apache.camel.util.IntrospectionSupport
setProperty - Configured property: host on bean:
org.apache.camel.component.mqtt.MQTTConfiguration@5e293bcb with value:
tcp://xx.xx.xx.xx:1882
[DEBUG] 2016-04-26 09:56:22,983 org.apache.camel.util.IntrospectionSupport
setProperty - Configured property: qualityOfService on bean:
org.apache.camel.component.mqtt.MQTTConfiguration@5e293bcb with value:
AtLeastOnce
[DEBUG] 2016-04-26 09:56:22,987 org.apache.camel.util.IntrospectionSupport
setProperty - Configured property: publishTopicName on bean:
org.apache.camel.component.mqtt.MQTTConfiguration@5e293bcb with value: logs
[DEBUG] 2016-04-26 09:56:22,997 org.apache.camel.util.IntrospectionSupport
setProperty - Configured property: userName on bean:
org.apache.camel.component.mqtt.MQTTConfiguration@5e293bcb with value:
xxtest:xx
[DEBUG] 2016-04-26 09:56:23,006 org.apache.camel.util.IntrospectionSupport
setProperty - Configured property: password on bean:
org.apache.camel.component.mqtt.MQTTConfiguration@5e293bcb with value: xx
[DEBUG] 2016-04-26 09:56:23,023 org.apache.camel.util.IntrospectionSupport
setProperty - Configured property: connectAttemptsMax on bean:
org.apache.camel.component.mqtt.MQTTConfiguration@5e293bcb with value: -1
[DEBUG] 2016-04-26 09:56:23,034 org.apache.camel.spring.SpringCamelContext
getEndpoint -
mqtt://xx?connectAttemptsMax=-1&host=tcp%3A%2F%2Fxx.xx.xx.xx%3A1882&password=xxxxxx&publishTopicName=logs&qualityOfService=AtLeastOnce&userName=xxtest%3Axx
converted to endpoint:
Endpoint[mqtt:xx?host=tcp://xx.xx.xx.xx:1882&qualityOfService=AtLeastOnce&publishTopicName=logs&userName=xxtest:xx&password=xxxxxx&connectAttemptsMax=-1]
by component: org.apache.camel.component.mqtt.MQTTComponent@6428ddc2
[DEBUG] 2016-04-26 09:56:23,081
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer -
Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=endpoints,name="mqtt:xx\?host=tcp://xx.xx.xx.xx:1882&qualityOfService=AtLeastOnce&publishTopicName=logs&userName=xxtest:xx&password=xxxxxx&connectAttemptsMax=-1"
[DEBUG] 2016-04-26 09:56:23,128
org.apache.camel.processor.interceptor.DefaultChannel initChannel -
Initialize channel for target:
'To[mqtt:xx?host=tcp://xx.xx.xx.xx:1882&qualityOfService=AtLeastOnce&publishTopicName=logs&userName=xxtest:xx&password=xx&connectAttemptsMax=-1]'
[DEBUG] 2016-04-26 09:56:23,288
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer -
Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=tracer,name=BacklogTracer
[DEBUG] 2016-04-26 09:56:23,571
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer -
Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=tracer,name=BacklogDebugger
[DEBUG] 2016-04-26 09:56:24,192
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer -
Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=errorhandlers,name="DefaultErrorHandlerBuilder(ref:CamelDefaultErrorHandlerBuilder)"
[INFO] 2016-04-26 09:56:24,211 org.apache.camel.spring.SpringCamelContext
doStartCamel - AllowUseOriginalMessage is enabled. If access to the original
message is not needed, then its recommended to turn this option off as it
may improve performance.
[INFO] 2016-04-26 09:56:24,213 org.apache.camel.spring.SpringCamelContext
doStartCamel - StreamCaching is not in use. If using streams then its
recommended to enable stream caching. See more details at
http://camel.apache.org/stream-caching.html
[DEBUG] 2016-04-26 09:56:24,216 org.apache.camel.spring.SpringCamelContext
doWarmUpRoutes - Warming up route id: route1 having autoStartup=true
[DEBUG] 2016-04-26 09:56:24,221 org.apache.camel.impl.RouteService warmUp -
Starting services on route: route1
[DEBUG] 2016-04-26 09:56:24,237 org.apache.camel.component.jms.JmsEndpoint
configureListenerContainer - Using destinationName: xxTopic on
listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@6afd37be
[DEBUG] 2016-04-26 09:56:24,543
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer -
Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=threadpools,name="JmsConsumer(0x2d7c876)"
[DEBUG] 2016-04-26 09:56:24,546
org.apache.camel.impl.DefaultExecutorServiceManager newCachedThreadPool -
Created new CachedThreadPool for source:
Consumer[activemq://topic://xxTopic?clientId=2&durableSubscriptionName=mqtt]
with name: JmsConsumer[bmrsTopic]. ->
java.util.concurrent.ThreadPoolExecutor@24a9bc6f[Running, pool size = 0,
active threads = 0, queued tasks = 0, completed tasks = 0]
[DEBUG] 2016-04-26 09:56:24,549 org.apache.camel.impl.RouteService
startChildService - Starting child service on route: route1 ->
Channel[sendTo(Endpoint[mqtt:xx?host=tcp://xx.xx.xx.xx:1882&qualityOfService=AtLeastOnce&publishTopicName=logs&userName=xxtest:xx&password=xxxxxx&connectAttemptsMax=-1])]
[DEBUG] 2016-04-26 09:56:24,771
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer -
Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=producers,name=MQTTProducer(0x329dd399)
[INFO] 2016-04-26 09:56:24,798 org.apache.camel.component.mqtt.MQTTEndpoint
connect - Connecting to tcp://xx.xx.xx.xx:1882 using 10 seconds timeout
[DEBUG] 2016-04-26 09:56:34,801 org.apache.camel.component.mqtt.MQTTProducer
doStop - Stopping producer:
Producer[mqtt:xx?host=tcp://xx.xx.xx.xx:1882&qualityOfService=AtLeastOnce&publishTopicName=logs&userName=xxtest:xx&password=xxxxxx&connectAttemptsMax=-1]
[INFO] 2016-04-26 09:56:34,816 org.apache.camel.spring.SpringCamelContext
doStop - Apache Camel 2.17.0 (CamelContext: camel-1) is shutting down
[DEBUG] 2016-04-26 09:56:34,824
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager doStop - Shutting
down with no inflight threads.
[DEBUG] 2016-04-26 09:56:34,842 org.apache.camel.impl.RouteService doStop -
Stopping services on route: route1
[DEBUG] 2016-04-26 09:56:34,845 org.apache.camel.impl.RouteService
stopChildService - Shutting down child service on route: route1 ->
Consumer[activemq://topic://xxTopic?clientId=2



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

Mime
View raw message