Hadrian: thanks for your valuable feedback.
this is my partial route:
<route id="ping-digi" startupOrder="2">
<from uri="jms:digiQueue" />
<setHeader
headerName="DigiId"><simple>${body}</simple></setHeader>
<setHeader
headerName="DigiUri"><simple>netty:tcp://${body}?sync=true</simple></setHeader>
<to uri="jms:TCPQueue" />
</route>
<route startupOrder="3">
<from uri="jms:TCPQueue" />
<routingSlip><header>DigiUri</header></routingSlip>
<to uri="jms:TCPReply"/>
</route>
The first route (from above) works fine.
in the second route, it works fine up to routingSlip where DigiUri=
netty:tcp://localhost:9900?sync=true
I have written a server program that send a string to the Client using the
following code:
String myMessage="This is my message" ;
outputToClient.writeBytes(myMessage);
I first start the server program then execute my camel application.
When the route start, I see message "This is my message" on the serve side
since I have followling line in the server program:
jta.append("Message Sent: " + myMessage + '\n');
But the message is not put in the "TCPReply" queue.
Please suggest how to fix this error.
--------------------------------------------------------------
I am getting the following error:
2011-11-21 17:57:56,094 [enerContainer-1] DEBUG NettyProducer
- Writing body: localhost:9900
2011-11-21 17:57:56,109 [ent worker #1-1] DEBUG NettyProducer
- Operation complete org.jboss.netty.channel.DefaultChannelFuture@18a8ae7
2011-11-21 17:57:59,438 [ent worker #1-1] DEBUG ClientChannelHandler
- Closing channel as an exception was thrown from Netty
java.io.IOException: An existing connection was forcibly closed by the
remote host
at sun.nio.ch.SocketDispatcher.read0(Native Method)[:1.6.0_26]
at
sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:25)[:1.6.0_26]
at
sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:202)[:1.6.0_26]
at sun.nio.ch.IOUtil.read(IOUtil.java:169)[:1.6.0_26]
at
sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:243)[:1.6.0_26]
at
org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:321)[org.apache.servicemix.bundles.netty-3.2.5.Final_1.jar:]
at
org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:280)[org.apache.servicemix.bundles.netty-3.2.5.Final_1.jar:]
at
org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:200)[org.apache.servicemix.bundles.netty-3.2.5.Final_1.jar:]
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_26]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_26]
at java.lang.Thread.run(Thread.java:662)[:1.6.0_26]
2011-11-21 17:57:59,469 [ent worker #1-1] DEBUG DefaultErrorHandler
- Failed delivery for exchangeId: ID:t00631529-2821-1321916275234-0:0:1:1:1.
On delivery attempt:
-----------------------------------------------------------------------------------
--
View this message in context:
http://camel.465427.n5.nabble.com/Failed-delivery-for-exchangeId-On-delivery-attempt-tp5012017p5012017.html
Sent from the Camel - Users mailing list archive at Nabble.com.
