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.
