git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: camel and mqtt (ServiceMix)


Hi

It seems you get some kind of timeout.

You can also try the paho component for mqtt. It may be better as it
uses the Eclipse Paho library.
https://github.com/apache/camel/blob/master/components/camel-paho/src/main/docs/paho-component.adoc

On Mon, Apr 16, 2018 at 1:03 PM, Massimiliano Cuccia
<massimiliano.cuccia@xxxxxxxxx> wrote:
> 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
> &amp;subscribeTopicNames=test"/>
>       <to uri="file:mqstream.out" />
>     </route>
>   </camelContext>
> </blueprint>
>
> ----------------------- other bundle I tried
> tested using & instead of &amp;
> <from uri="mqtt:aaa?host=tcp://192.168.3.200:1883
> &subscribeTopicNames=test"/>
> tested using ; instead of &amp;
> <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
> &amp;subscribeTopicName=temp/random"/>
> and
> <from uri="mqtt:ttt?host=tcp://37.187.106.16:1883"/>
>
> none of these works
> please help
> --
> MC//ac2



-- 
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2



( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-camel-users/msg03255.html on line 279
Call Stack
#TimeMemoryFunctionLocation
10.0007372632{main}( ).../msg03255.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-camel-users/msg03255.html on line 279
Call Stack
#TimeMemoryFunctionLocation
10.0007372632{main}( ).../msg03255.html:0