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.

Reply via email to