Re: Problem in mqtt Component

[Jinesh M.K]

Hi Jiang,

Thanks for rthe eply

On 24 May 2013 07:38, Willem jiang <willem.ji...@gmail.com> wrote:

> Hi
>
> Did you push some message to the topic which the route is subscribed?
>

Yes, using some Java MQTT client

Can you add some log between your first route from and to endpoints?


I done like this
<camel:route>
            <camel:from
uri="mqtt:foo?host=tcp://myhost:1883&amp;subscribeTopicName=test/#" />
               <camel:log message="Message Arrived" />
            <camel:to
uri="mqtt:bar?host=tcp://myhost:1883&amp;publishTopicName=test1/test" />
            <camel:log message="Message processed" />
  </camel:route>

In this case 'Message Arrived' print immediately when the message pushed
from a java MQTT publisher,, but "Message processed" take long time to
print and publisher is not working.(I tried it with some Java MQTT
subscriber)


>
>
> --
> Willem Jiang
>
> Red Hat, Inc.
> FuseSource is now part of Red Hat
> Web: http://www.fusesource.com | http://www.redhat.com
> Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/)
> (English)
>           http://jnn.iteye.com (http://jnn.javaeye.com/) (Chinese)
> Twitter: willemjiang
> Weibo: 姜宁willem
>
>
>
>
>
> On Thursday, May 23, 2013 at 11:34 PM, Jinesh M.K wrote:
>
> > Hi,
> >
> > I have some problem with mqtt end point using spring DSL. Here my route
> > definition
> >
> >
> >
> > <camel:route>
> > <camel:from
> > uri="mqtt:foo?host=tcp://myhost:1883&amp;subscribeTopicName=test/#" />
> > <camel:to
> > uri="mqtt:bar?host=tcp:/myhost:1883&amp;publishTopicName=test1/test" />
> > <camel:log message="Message processed" />
> > </camel:route>
> >
> > Using this route definition, the program taking long time to print the
> log
> > message and nothing is published under test1/test topic. If I remove any
> > one the mqtt route. It will works fine. For example
> >
> > <camel:route>
> > <camel:from
> > uri="mqtt:foo?host=tcp://myhost:1883&amp;subscribeTopicName=test/#" />
> > <camel:to uri="file:/myhome/test" />
> > <camel:log message="Message processed" />
> > </camel:route>
> >
> > or
> >
> > <camel:route>
> > <camel:from uri="file:/myhome/test" />
> > <camel:to
> > uri="mqtt:bar?host=tcp:/myhost:1883&amp;publishTopicName=test1/test" />
> > <camel:log message="Message processed" />
> > </camel:route>
> >
> > Both these condition works fine. Problem only using mqtt in from and to
> > route.
> >
> > Any idea about it?
> >
> > Thanks in advance
> > --
> > Jinesh M.K
> > <mkjin...@gmail.com (mailto:mkjin...@gmail.com)>
>
>
>
>


-- 
Jinesh M.K
Research Associate
Amrita Center for Cyber Security | Amrita Vishwa Vidyapeetham
(+91) 9400466629 | 0476 2804530
http://jinutechworld.blogspot.com | mkjin...@gmail.com