The consumer for which which queue was closed? Can you share the complete stack trace?
Best, Christian Müller ----------------- 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, Jun 19, 2013 at 9:18 AM, indrayani <ind.k...@gmail.com> wrote: > hi, > thanks for the quick reply. > > actually my scenario is little different , I am not creating any consumer > on > camel side. I have just defined routes . > if you have some time, then can you please check the following scenario. > what is happening is, first and second time communication works fine, but > for the third time I am getting > consumer closed and session closed exceptions. > It would be really helpful if you check the following scenario and help me > out . > ------------------------------------------------ > > the communication is happening between two applications deployed on tomcat > via camel applicaiton which is also deployed on tomcat. > > > camel routes are as follows : > > public void configure() { > from("servlet:///servletA") > .process(new Processor() { > > @Override > public void process(Exchange exchange) > throws Exception { > System.out.println("*** from > servletA to activemq inbox"); > > } > }) > .to("activemq:queue:inbox"); > > from("activemq:queue:inbox") > .setHeader(Exchange.HTTP_METHOD, constant("POST")) > .process(new Processor() { > > @Override > public void process(Exchange exchange) throws > Exception { > System.out.println("*** from activemq inbox > to applicationB"); > > } > }) > .to > ("http://localhost:8082/applicationB/a.do?bridgeEndpoint=true";) > .process(new Processor() { > > @Override > public void process(Exchange exchange) throws > Exception { > System.out.println("*** from applicationB > back to the caller that is servletA"); > exchange.getOut().setHeader("JOB_NO", > exchange.getIn().getHeader("JOB_NO")); > } > }); > > > from("servlet:///servletC") > .process(new Processor() { > > @Override > public void process(Exchange exchange) throws > Exception { > System.out.println("*** from servletC to > activemq inboxD"); > > } > }) > .to("activemq:queue:inboxD"); > > from("activemq:queue:inboxD") > .setHeader(Exchange.HTTP_METHOD, constant("POST")) > .process(new Processor() { > > @Override > public void process(Exchange exchange) throws > Exception { > System.out.println("*** from activemq > inboxD > to applicationE"); > } > }) > > .to(ExchangePattern.InOnly," > http://localhost:8082/applicationE/agentResp?bridgeEndpoint=true";); > > } > > Please let me know if you need any more details. > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140p5734337.html > Sent from the Camel - Users mailing list archive at Nabble.com. >
