You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by sambardar <sa...@yahoo.com> on 2012/03/20 17:39:03 UTC
Apache >> Camel >> ActiveMq
I am getting an exception when starting the routes that has ActiveMq
component in it. It is complaining about not able te resolve the reply
Destination. What setting am i missing ?
The exception is:
Failed delivery for exchangeId: ID-NCPC5MTVC91-4021-1332260165476-0-6.
Exhausted after delivery attempt: 1 caught:
org.apache.camel.RuntimeExchangeException: Failed to resolve replyTo
destination on the exchange: Exchange[Message: From kpi generator]
My routes look like following:
<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri = "netty:tcp://localhost:1556?textline=true" />
<process ref="perProcessor" />
<to uri = "bean:perParserBean" />
<multicast>
<to uri = "bean:kpiGeneratorBean" />
<pipeline>
<to uri = "activeMq:queue:internal" />
<to uri = "bean:xdrWriterBean" />
</pipeline>
</multicast>
</route>
<route>
<from uri = "bean:kpiGeneratorBean" />
<to uri = "activeMq:queue:internal"/>
<to uri = "bean:xdrWriterBean"/>
</route>
</camelContext>
--
View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-ActiveMq-tp5580552p5580552.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Apache >> Camel >> ActiveMq
Posted by sambardar <sa...@yahoo.com>.
It doesn't work even if i just send the message directly from netty endpoint
without modifying the body
--
View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-ActiveMq-tp5580552p5587190.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Apache >> Camel >> ActiveMq
Posted by Claus Ibsen <cl...@gmail.com>.
On Thu, Mar 22, 2012 at 9:00 AM, sambardar <sa...@yahoo.com> wrote:
> it is just a test for now. kpigeneratorBean simply sets a test message "From
> KPI Bean" in the body of the message.
>
> Basically it has just 1 line: e.getOut().setBody("From KPI Bean"); In fact
> if i route the message directly from netty component to the queue, i still
> get the error.
>
See this FAQ
http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
Rule of thumb, favor using getIn over getOut.
> --
> View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-ActiveMq-tp5580552p5584987.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
--
Claus Ibsen
-----------------
CamelOne 2012 Conference, May 15-16, 2012: http://camelone.com
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
Re: Apache >> Camel >> ActiveMq
Posted by sambardar <sa...@yahoo.com>.
it is just a test for now. kpigeneratorBean simply sets a test message "From
KPI Bean" in the body of the message.
Basically it has just 1 line: e.getOut().setBody("From KPI Bean"); In fact
if i route the message directly from netty component to the queue, i still
get the error.
--
View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-ActiveMq-tp5580552p5584987.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Apache >> Camel >> ActiveMq
Posted by Willem Jiang <wi...@gmail.com>.
Hi,
What are you doing in the bean:kpiGeneratorBean?
BTW, when you using the multicast, you need to enable the stream
cache[1] to support stream consuming in different endpoints.
[1]http://camel.apache.org/stream-caching.html
On Wed Mar 21 03:27:29 2012, sambardar wrote:
> In fact the trace i sent already is when it makes second delivery attempt and
> after. In the first delivery attempt the trace is as below. It seems that
> messages are simply not being delivered to the ActiveMQ queue
>
> ==========================================
> TRACE
> ===========================================
> [ New I/O server worker #1-1] DefaultErrorHandler ERROR Failed
> delivery for exchangeId: ID-NCPC5MTVC91-4808-1332269867125-0-1. Exhausted
> after delivery attempt: 1 caught: org.apache.camel.CamelExecutionException:
> Exception occurred during execution on the exchange: Exchange[Message: test
> message]
> org.apache.camel.CamelExecutionException: Exception occurred during
> execution on the exchange: Exchange[Message: test message]
> at
> org.apache.camel.util.ObjectHelper.wrapCamelExecutionException(ObjectHelper.java:1212)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.impl.DefaultExchange.setException(DefaultExchange.java:282)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:315)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:110)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:71)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:322)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:213)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:71)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:86)[camel-core-2.9.0.jar:2.9.0]
> at
> org.apache.camel.component.netty.handlers.ServerChannelHandler.messageReceived(ServerChannelHandler.java:91)[camel-netty-2.9.0.jar:2.9.0]
> at
> org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:783)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:302)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:76)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:783)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:302)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:317)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:299)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:214)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:274)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:261)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:351)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:282)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:202)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:44)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_27]
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-ActiveMq-tp5580552p5580982.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
--
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang
Re: Apache >> Camel >> ActiveMq
Posted by sambardar <sa...@yahoo.com>.
In fact the trace i sent already is when it makes second delivery attempt and
after. In the first delivery attempt the trace is as below. It seems that
messages are simply not being delivered to the ActiveMQ queue
==========================================
TRACE
===========================================
[ New I/O server worker #1-1] DefaultErrorHandler ERROR Failed
delivery for exchangeId: ID-NCPC5MTVC91-4808-1332269867125-0-1. Exhausted
after delivery attempt: 1 caught: org.apache.camel.CamelExecutionException:
Exception occurred during execution on the exchange: Exchange[Message: test
message]
org.apache.camel.CamelExecutionException: Exception occurred during
execution on the exchange: Exchange[Message: test message]
at
org.apache.camel.util.ObjectHelper.wrapCamelExecutionException(ObjectHelper.java:1212)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.impl.DefaultExchange.setException(DefaultExchange.java:282)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:315)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:110)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:71)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:322)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:213)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:71)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:86)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.component.netty.handlers.ServerChannelHandler.messageReceived(ServerChannelHandler.java:91)[camel-netty-2.9.0.jar:2.9.0]
at
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:783)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:302)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:76)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:783)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:302)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:317)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:299)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:214)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:274)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:261)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:351)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:282)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:202)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:44)[org.apache.servicemix.bundles.netty-3.2.6.Final_1.jar:]
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_27]
--
View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-ActiveMq-tp5580552p5580982.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Apache >> Camel >> ActiveMq
Posted by Claus Ibsen <cl...@gmail.com>.
Hi
What version of Camel are you using?
How did you configure AMQ?
Did it work previously?
Post the full stacktrace
On Tue, Mar 20, 2012 at 5:39 PM, sambardar <sa...@yahoo.com> wrote:
> I am getting an exception when starting the routes that has ActiveMq
> component in it. It is complaining about not able te resolve the reply
> Destination. What setting am i missing ?
> The exception is:
> Failed delivery for exchangeId: ID-NCPC5MTVC91-4021-1332260165476-0-6.
> Exhausted after delivery attempt: 1 caught:
> org.apache.camel.RuntimeExchangeException: Failed to resolve replyTo
> destination on the exchange: Exchange[Message: From kpi generator]
>
> My routes look like following:
> <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
>
>
>
> <route>
> <from uri = "netty:tcp://localhost:1556?textline=true" />
> <process ref="perProcessor" />
> <to uri = "bean:perParserBean" />
> <multicast>
> <to uri = "bean:kpiGeneratorBean" />
> <pipeline>
> <to uri = "activeMq:queue:internal" />
> <to uri = "bean:xdrWriterBean" />
> </pipeline>
> </multicast>
> </route>
>
>
> <route>
> <from uri = "bean:kpiGeneratorBean" />
> <to uri = "activeMq:queue:internal"/>
> <to uri = "bean:xdrWriterBean"/>
> </route>
> </camelContext>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-ActiveMq-tp5580552p5580552.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
--
Claus Ibsen
-----------------
CamelOne 2012 Conference, May 15-16, 2012: http://camelone.com
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
Re: Apache >> Camel >> ActiveMq
Posted by sambardar <sa...@yahoo.com>.
Camel Version 2.9.0. I am trying to run these routes for first time and i am
getting this exception at the start of the routes itself. Everything is
configured in the xml file. I am pasting full xml file followed by complete
stack trace:
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:camel="http://camel.apache.org/schema/spring"
xmlns:broker="http://activemq.apache.org/schema/core"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core-5.5.0.xsd">
<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri = "netty:tcp://localhost:1556?textline=true" />
<process ref="perProcessor" />
<to uri = "bean:perParserBean" />
<multicast>
<to uri = "bean:kpiGeneratorBean" />
<pipeline>
<to uri = "activeMq:queue:internal" />
<to uri = "bean:xdrWriterBean" />
</pipeline>
</multicast>
</route>
<route>
<from uri = "bean:kpiGeneratorBean" />
<to uri = "activeMq:queue:internal"/>
<to uri = "bean:xdrWriterBean"/>
</route>
</camelContext>
<broker:broker id="broker" useJmx="true" persistent="false"
brokerName="localhost">
<broker:transportConnectors>
<broker:transportConnector name="tcp" uri="tcp://localhost:61616"/>
</broker:transportConnectors>
</broker:broker>
<bean id="activeMq"
class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="brokerURL" value="tcp://localhost:61616" />
</bean>
<bean id="perProcessor" class="com.xih.mediation.PerProcessor" />
<bean id="kpiGeneratorBean" class="com.xih.mediation.KpiGeneratorBean" />
<bean id="perParserBean" class="com.xih.mediation.PerParserBean" />
<bean id="xdrWriterBean" class="com.xih.mediation.XdrWriterBean" />
</beans>
=============================================================================
STACK TRACE
==============================================================================
2 - bean://kpiGeneratorBean] TemporaryQueueReplyManager WARN ReplyTo
destination was not set and timeout occurred
2 - bean://kpiGeneratorBean] DefaultErrorHandler ERROR Failed
delivery for exchangeId: ID-NCPC5MTVC91-4021-1332260165476-0-6. Exhausted
after delivery attempt: 1 caught: org.apache.camel.RuntimeExchangeException:
Failed to resolve replyTo destination on the exchange: Exchange[Message:
>From kpi generator]
apache.camel.RuntimeExchangeException: Failed to resolve replyTo destination
on the exchange: Exchange[Message: From kpi generator]
at
org.apache.camel.component.jms.JmsProducer$1.createMessage(JmsProducer.java:149)[camel-jms-2.7.0.jar:2.7.0]
at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.doSendToDestination(JmsConfiguration.java:196)[camel-jms-2.7.0.jar:2.7.0]
at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.access$100(JmsConfiguration.java:139)[camel-jms-2.7.0.jar:2.7.0]
at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate$1.doInJms(JmsConfiguration.java:153)[camel-jms-2.7.0.jar:2.7.0]
at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)[spring-jms-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:150)[camel-jms-2.7.0.jar:2.7.0]
at
org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:351)[camel-jms-2.7.0.jar:2.7.0]
at
org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:161)[camel-jms-2.7.0.jar:2.7.0]
at
org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:96)[camel-jms-2.7.0.jar:2.7.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:115)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:285)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:110)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:71)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:322)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:213)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:71)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:86)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.impl.DefaultScheduledPollConsumer.poll(DefaultScheduledPollConsumer.java:64)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:140)[camel-core-2.9.0.jar:2.9.0]
at
org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:92)[camel-core-2.9.0.jar:2.9.0]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)[:1.6.0_27]
at
java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)[:1.6.0_27]
at
java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)[:1.6.0_27]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)[:1.6.0_27]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:180)[:1.6.0_27]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:204)[:1.6.0_27]
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_27]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_27]
at java.lang.Thread.run(Thread.java:662)[:1.6.0_27]
--
View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-ActiveMq-tp5580552p5580801.html
Sent from the Camel - Users mailing list archive at Nabble.com.