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.