ZeroMQ publishing infinte number of times

[harikrish07121991]

Using the following creating a dynamic ZeroMQ  route 
                <camel:route>
                        <camel:from uri="seda:sample"/>
                        <log message="stream slip message=${body}" />
                        <camel:dynamicRouter>
                                <camel:method ref="streamSlip" method="slip" />
                        </camel:dynamicRouter>
                </camel:route>
 

And slip function is :
        public String slip(Exchange exchange)
        {
                log.info("publishing");
                String body = exchange.getIn().getBody(String.class);
                log.info("Exchange body"+body);
                return 
"zeromq:tcp://0.0.0.0:5577?socketType=PUBLISH&topics=iotm/stream";
        }


But the problem is the zeroMQ is publishing it infinite times the same
message.

Is it the problem with the zeroMQ URL??
Please help ..



--
View this message in context: 
http://camel.465427.n5.nabble.com/ZeroMQ-publishing-infinte-number-of-times-tp5744307.html
Sent from the Camel - Users mailing list archive at Nabble.com.