Hi, I would like to use Camel inside a ServiceMix project, I wrote a sample bundle to test functionality BUT I have a problem consuming MQtt messages.
the task is in state "Active", but messages aren't received, I can see this error in log file: "java.util.concurrent.TimeoutException: null" what is this message referred to? I don't understand what's going wrong In the documentation seems so simple to achieve this task, but I can't avoid this error. Anyone already had similar problems? Please reply with any useful advice. I added to this email the log section and the xml of my test bundle and other details ----------------------- Software versions I'm running Karaf (4.2.0), Camel (2.20.0), camel-mqtt (2.20.0) the MQtt broker is a Mosquitto 1.4.15 running in an Ubuntu 16.04.4 LTS (working: tested using a python client) the broker is fed by a python client that send messages every 5 seconds ----------------------- output of bundle:list 242 │ Active │ 80 │ 0.0.0 │ maxc-rout.xml ----------------------- logfile 2018-04-16T12:21:29,958 | INFO | fileinstall-/home/ute/apache-karaf-4.2.0/deploy | fileinstall | 9 - org.apache.felix.fileinstall - 3.6.4 | Installing bundle maxc-rout.xml / 0.0.0 2018-04-16T12:21:30,098 | INFO | Blueprint Event Dispatcher: 1 | BlueprintCamelContext | 49 - org.apache.camel.camel-blueprint - 2.20.0 | Attempting to start Camel Context camel-2 2018-04-16T12:21:30,100 | INFO | Blueprint Event Dispatcher: 1 | BlueprintCamelContext | 49 - org.apache.camel.camel-blueprint - 2.20.0 | Apache Camel 2.20.0 (CamelContext: camel-2) is starting 2018-04-16T12:21:30,100 | INFO | Blueprint Event Dispatcher: 1 | ManagedManagementStrategy | 51 - org.apache.camel.camel-core - 2.20.0 | JMX is enabled 2018-04-16T12:21:30,248 | INFO | Blueprint Event Dispatcher: 1 | BlueprintCamelContext | 49 - org.apache.camel.camel-blueprint - 2.20.0 | 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 2018-04-16T12:21:30,274 | INFO | Blueprint Event Dispatcher: 1 | MQTTEndpoint | 206 - org.apache.camel.camel-mqtt - 2.20.0 | Connecting to tcp://192.168.3.200:1883 using 10 seconds timeout 2018-04-16T12:21:40,276 | INFO | Blueprint Event Dispatcher: 1 | BlueprintCamelContext | 49 - org.apache.camel.camel-blueprint - 2.20.0 | Apache Camel 2.20.0 (CamelContext: camel-2) is shutting down 2018-04-16T12:21:40,281 | INFO | Blueprint Event Dispatcher: 1 | BlueprintCamelContext | 49 - org.apache.camel.camel-blueprint - 2.20.0 | Apache Camel 2.20.0 (CamelContext: camel-2) uptime 10.182 seconds 2018-04-16T12:21:40,282 | INFO | Blueprint Event Dispatcher: 1 | BlueprintCamelContext | 49 - org.apache.camel.camel-blueprint - 2.20.0 | Apache Camel 2.20.0 (CamelContext: camel-2) is shutdown in 0.006 seconds 2018-04-16T12:21:40,282 | ERROR | Blueprint Event Dispatcher: 1 | BlueprintCamelContext | 49 - org.apache.camel.camel-blueprint - 2.20.0 | Error occurred during starting Camel Context camel-2 java.util.concurrent.TimeoutException: null at org.fusesource.mqtt.client.Promise.await(Promise.java:83) ~[?:?] at org.apache.camel.component.mqtt.MQTTEndpoint.connect(MQTTEndpoint.java:342) ~[?:?] at org.apache.camel.component.mqtt.MQTTConsumer.doStart(MQTTConsumer.java:38) ~[?:?] at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:3688) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:4006) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3941) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3861) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3625) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3477) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:208) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:3236) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:3232) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3255) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:3232) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:3155) ~[51:org.apache.camel.camel-core:2.20.0] at org.apache.camel.blueprint.BlueprintCamelContext.start(BlueprintCamelContext.java:244) ~[49:org.apache.camel.camel-blueprint:2.20.0] at org.apache.camel.blueprint.BlueprintCamelContext.maybeStart(BlueprintCamelContext.java:284) ~[49:org.apache.camel.camel-blueprint:2.20.0] at org.apache.camel.blueprint.BlueprintCamelContext.blueprintEvent(BlueprintCamelContext.java:177) [49:org.apache.camel.camel-blueprint:2.20.0] at org.apache.aries.blueprint.container.BlueprintEventDispatcher$3.call(BlueprintEventDispatcher.java:190) [45:org.apache.aries.blueprint.core:1.9.0] at org.apache.aries.blueprint.container.BlueprintEventDispatcher$3.call(BlueprintEventDispatcher.java:188) [45:org.apache.aries.blueprint.core:1.9.0] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:?] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:?] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:?] at java.lang.Thread.run(Thread.java:748) [?:?] 2018-04-16T12:21:40,289 | INFO | fileinstall-/home/ute/apache-karaf-4.2.0/deploy | fileinstall | 9 - org.apache.felix.fileinstall - 3.6.4 | Started bundle: blueprint:file:/home/ute/apache-karaf-4.2.0/deploy/maxc-rout.xml ----------------------- This is the bundle I deploy <?xml version="1.0" encoding="UTF-8"?> <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd"> <camelContext xmlns="http://camel.apache.org/schema/blueprint"> <route id="route1"> <from uri="mqtt:aaa?host=tcp://192.168.3.200:1883 &subscribeTopicNames=test"/> <to uri="file:mqstream.out" /> </route> </camelContext> </blueprint> ----------------------- other bundle I tried tested using & instead of & <from uri="mqtt:aaa?host=tcp://192.168.3.200:1883 &subscribeTopicNames=test"/> tested using ; instead of & <from uri="mqtt:bbb?host=tcp://192.168.3.200:1883;subscribeTopicName=test"/> tested using a public mqtt broker (produce random messages) <from uri="mqtt:ttt?host=tcp://37.187.106.16:1883 ;subscribeTopicName=temp/random"/> and <from uri="mqtt:ttt?host=tcp://37.187.106.16:1883 &subscribeTopicName=temp/random"/> and <from uri="mqtt:ttt?host=tcp://37.187.106.16:1883"/> none of these works please help -- MC//ac2