hi,
I am using Camel netty tcp producer to send messages to a server listening
on TCP port.
my route looks like this:
<to uri="netty:tcp://
127.0.0.1:2944?requestTimeout=30000&decoderMaxLineLength=4048&synchronous=true&sync=true&allowDefaultCodec=false&decoders=#gwaymessageDecoder
"/>
<process
ref="api.gway.tcp_endpoint.delete.resp.processor"/>
The server is responding with a message which was received by the TCP
component. this I can see in the TRACE log as below.
Thread #1 -
NettyClientTCPWorker];1;DEBUG;org.apache.camel.component.netty.NettyProducer;Channel:
[id: 0xd25ccb0d, L:/127.0.0.1:52474 - R:127.0.0.1/127.0.0.1:2944] received
body: java.nio.HeapByteBuffer[pos=0 lim=36 cap=36]
But still, the camel exception of no response received from the remote
server is thrown and the route processing is stopped.
am I missing something? not able to find much info in the documentation.
any pointers would be helpful.
RouteId ProcessorId Processor
Elapsed (ms)
[tcp_endpoint-delet] [tcp_endpoint-delet]
[from[servlet:/org/deleting?httpMethodRestrict=DELETE%2COPTIONS&optionsEnabled=]
[ 4192]
...[tcp_endpoint-delet] [process8 ]
[ref:api.gway.tcp_endpoint.delete.resp.processor
] [ 0]
Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
org.apache.camel.CamelExchangeException: No response received from remote
server: 127.0.0.1:2944. Exchange[AEC764CF26D0E12-0000000000000000]
at
org.apache.camel.component.netty.handlers.ClientChannelHandler.channelInactive(ClientChannelHandler.java:133)
~[camel-netty-3.7.0.jar:3.7.0]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:241)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:389)
~[netty-codec-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:354)
~[netty-codec-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:241)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1405)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:901)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.channel.AbstractChannel$AbstractUnsafe$8.run(AbstractChannel.java:819)
~[netty-transport-4.1.55.Final.jar:4.1.55.Final]
at
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
~[netty-common-4.1.55.Final.jar:4.1.55.Final]
--
Regards,
Rohan Emmanuel