camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From anandsk <sku...@arccorp.com>
Subject Mina async route not working
Date Tue, 02 Mar 2010 16:10:05 GMT

Hi,
I tried this route with camel 2.2 and it is not forwarding response to end
point defined in async "direct:response". also I see the logs showing that
mina producer receiving the message back from tcp server but it is not
forwarding them to async endpoint. am I doing this wrong.

Thanks,
Anand
		from("mina:tcp://localhost:6202?textline=true&sync=true").process(new
Processor() {
		    public void process(Exchange exchange) throws Exception {
		        String body = exchange.getIn().getBody(String.class);
		        //Thread.currentThread();
				Thread.sleep(1000);
		        exchange.getOut().setBody("Bye 1" + body+"\n");
		        //exchange.getOut().setBody("Bye 2" + body+"\n");
		    }
		});
 

		//from("jms:test.Camel1")
		from("file:///test/test/response")
		.convertBodyTo(String.class).threads(1)
		//.to("log:jms.queue.message")
		//.bean(smooks.StatusRequestMessageHandler.class)
		//.setHeader(MinaEndpoint.HEADER_MINA_IOSESSION, expression)
		.to("mina:tcp://localhost:6202?textline=true&sync=true")
		.toAsync("direct:response",1)
		.to("log:direct");	
		
			from("direct:response")
			.to("log:jms.queue.message");
-- 
View this message in context: http://old.nabble.com/Mina-async-route-not-working-tp27757690p27757690.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Mime
View raw message