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
