org.apache.camel.CamelException: Cannot connect to
Hi , while performing load testing on the following route I am getting these error for *some *messages from("netty:tcp://0.0.0.0:7000?textline=true") .bean(MainDummyProcessor.class) .to("netty:tcp://0.0.0.0:7001?textline=true").to("netty:tcp://0.0.0.0:7004?textline=true") .bean(MainDummyProcessor.class) .to("netty:tcp://0.0.0.0:7002?textline=true").to("netty:tcp://0.0.0.0:7004?textline=true") .bean(MainDummyProcessor.class) .to("netty:tcp://0.0.0.0:7003?textline=true").to("netty:tcp://0.0.0.0:7004?textline=true") .bean(MainDummyProcessor.class); Here is the full stacktrace ERROR 10 Jul 2013 12:32:35,252 org.apache.camel.processor.DefaultErrorHandler - Failed delivery for (MessageId: ID-FSSCHN61-59989-1373476603039-0-73530 on ExchangeId: ID-FSSCHN61-59989-1373476603039-0-61620). Exhausted after delivery attempt: 1 caught: org.apache.camel.CamelException: Cannot connect to 0.0.0.0:7001 org.apache.camel.CamelException: Cannot connect to 0.0.0.0:7001 at org.apache.camel.component.netty.NettyProducer.openChannel(NettyProducer.java:404) at org.apache.camel.component.netty.NettyProducer$NettyProducerPoolableObjectFactory.makeObject(NettyProducer.java:472) at org.apache.camel.component.netty.NettyProducer$NettyProducerPoolableObjectFactory.makeObject(NettyProducer.java:467) at org.apache.commons.pool.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:1188) at org.apache.camel.component.netty.NettyProducer.process(NettyProducer.java:215) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) at org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:122) at org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:298) at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:117) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:335) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220) at org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:46) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) at org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:308) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) at org.apache.camel.processor.Pipeline.process(Pipeline.java:117) at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) at org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:46) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) at org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150) at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117) at org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) at org.apache.camel.component.netty.handlers.ServerChannelHandler.processAsynchronously(ServerChannelHandler.java:118) at org.apache.camel.component.netty.handlers.ServerChannelHandler.messageReceived(ServerChannelHandler.java:102) at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
Re: org.apache.camel.CamelException: Cannot connect to
Will have a look in the coming week... Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://www.apache.org/foundation/ Apache Member: https://www.apache.org/foundation/members.html https://www.linkedin.com/pub/christian-mueller/11/551/642 On Wed, Jul 10, 2013 at 10:35 AM, kiranreddykasa wrote: > Hi , > > while performing load testing on the following route I am getting these > error for *some *messages > > from("netty:tcp://0.0.0.0:7000?textline=true") > .bean(MainDummyProcessor.class) > .to("netty:tcp://0.0.0.0:7001?textline=true").to("netty:tcp:// > 0.0.0.0:7004?textline=true") > .bean(MainDummyProcessor.class) > .to("netty:tcp://0.0.0.0:7002?textline=true").to("netty:tcp:// > 0.0.0.0:7004?textline=true") > .bean(MainDummyProcessor.class) > .to("netty:tcp://0.0.0.0:7003?textline=true").to("netty:tcp:// > 0.0.0.0:7004?textline=true") > .bean(MainDummyProcessor.class); > > > > Here is the full stacktrace > > ERROR 10 Jul 2013 12:32:35,252 > org.apache.camel.processor.DefaultErrorHandler - Failed delivery for > (MessageId: ID-FSSCHN61-59989-1373476603039-0-73530 on ExchangeId: > ID-FSSCHN61-59989-1373476603039-0-61620). Exhausted after delivery attempt: > 1 caught: org.apache.camel.CamelException: Cannot connect to 0.0.0.0:7001 > org.apache.camel.CamelException: Cannot connect to 0.0.0.0:7001 > at > > org.apache.camel.component.netty.NettyProducer.openChannel(NettyProducer.java:404) > at > > org.apache.camel.component.netty.NettyProducer$NettyProducerPoolableObjectFactory.makeObject(NettyProducer.java:472) > at > > org.apache.camel.component.netty.NettyProducer$NettyProducerPoolableObjectFactory.makeObject(NettyProducer.java:467) > at > > org.apache.commons.pool.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:1188) > at > > org.apache.camel.component.netty.NettyProducer.process(NettyProducer.java:215) > at > > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > > org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:122) > at > > org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:298) > at > org.apache.camel.processor.SendProcessor.process(SendProcessor.java:117) > at > > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99) > at > > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) > at > > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99) > at > > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > > org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91) > at > > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:335) > at > > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220) > at > > org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:46) > at > > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > > org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:308) > at > > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:117) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) > at > > org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:46) > at > > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > > org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150) > at > > org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117) > at > > org.apache.camel.processor.
Re: org.apache.camel.CamelException: Cannot connect to
When you using 0.0.0.0:7000 on the server side, netty will listen to all the net work interfaces, such as localhost and ips which you can access outside. But 0.0.0.0 don't work for the client side, because we don't know which address it really means, it could localhost or the other network interface. You'd better change the address to localhost just like this from("netty:tcp://0.0.0.0:7000?textline=true") .bean(MainDummyProcessor.class) .to("netty:tcp://0.0.0.0:7001?textline=true").to("netty:tcp://localhost:7004?textline=true") -- 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 Wednesday, July 10, 2013 at 4:35 PM, kiranreddykasa wrote: > Hi , > > while performing load testing on the following route I am getting these > error for *some *messages > > from("netty:tcp://0.0.0.0:7000?textline=true") > .bean(MainDummyProcessor.class) > .to("netty:tcp://0.0.0.0:7001?textline=true").to("netty:tcp://0.0.0.0:7004?textline=true") > .bean(MainDummyProcessor.class) > .to("netty:tcp://0.0.0.0:7002?textline=true").to("netty:tcp://0.0.0.0:7004?textline=true") > .bean(MainDummyProcessor.class) > .to("netty:tcp://0.0.0.0:7003?textline=true").to("netty:tcp://0.0.0.0:7004?textline=true") > .bean(MainDummyProcessor.class); > > > > Here is the full stacktrace > > ERROR 10 Jul 2013 12:32:35,252 > org.apache.camel.processor.DefaultErrorHandler - Failed delivery for > (MessageId: ID-FSSCHN61-59989-1373476603039-0-73530 on ExchangeId: > ID-FSSCHN61-59989-1373476603039-0-61620). Exhausted after delivery attempt: > 1 caught: org.apache.camel.CamelException: Cannot connect to 0.0.0.0:7001 > org.apache.camel.CamelException: Cannot connect to 0.0.0.0:7001 > at > org.apache.camel.component.netty.NettyProducer.openChannel(NettyProducer.java:404) > at > org.apache.camel.component.netty.NettyProducer$NettyProducerPoolableObjectFactory.makeObject(NettyProducer.java:472) > at > org.apache.camel.component.netty.NettyProducer$NettyProducerPoolableObjectFactory.makeObject(NettyProducer.java:467) > at > org.apache.commons.pool.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:1188) > at > org.apache.camel.component.netty.NettyProducer.process(NettyProducer.java:215) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:122) > at > org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:298) > at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:117) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:335) > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220) > at > org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:46) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:308) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:117) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) > at > org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:46) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90) > at > org.apache.camel.processor.UnitOfWorkProcessor.proce
Re: org.apache.camel.CamelException: Cannot connect to
Hi, As mentioned earlier only some of the requests (1%) are failing with the above exception, remaining all are processing successfully. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/org-apache-camel-CamelException-Cannot-connect-to-tp5735414p5735647.html Sent from the Camel - Users mailing list archive at Nabble.com.