Hi:
I have a Camel route that consumes from *netty:udp*, optionally sends a UDP
response back to client (if requested), and produces to a Kafka topic. I'm
getting the following exception which is causing netty to stop listening on
the configured UDP port. Any thoughts greatly appreciated!!!
Thanks, Steve
*The route:*
<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<route startupOrder="104" customId="true" id="ROUTE_ID_RAW_DTC_EVENTS"
xmlns="http://camel.apache.org/schema/spring";>
<from
uri="netty:udp://talend-es-edge-01.kiad0.s.mission.net:62265?serverPipelineFactory=#DTC_SERVER_PIPELINE_FACTORY_ROUTE_ID_RAW_DTC_EVENTS&keepAlive=true&sync=true&orderedThreadPoolExecutor=false&receiveBufferSize=8388608&sendBufferSize=8388608&allowDefaultCodec=false&disconnectOnNoReply=false&receiveBufferSizePredictor=8192"/>
<setProperty propertyName="CamelCharsetName" id="setProperty10">
<expressionDefinition>iso-8859-1</expressionDefinition>
</setProperty>
<threads poolSize="7" maxPoolSize="14"
threadName="threads_ROUTE_ID_RAW_DTC_EVENTS" callerRunsWhenRejected="true"
id="threads3">
<wireTap
uri="netty:udp://abinitio-edge-02.kiad0.s.mission.net:62265?clientPipelineFactory=#DTC_CLIENT_PIPELINE_FACTORY_ROUTE_ID_RAW_DTC_EVENTS&sync=false&sendBufferSize=8388608&allowDefaultCodec=false"
customId="true" id="ROUTE_ID_RAW_DTC_EVENTS_MIRROR"/>
<multicast parallelProcessing="true" id="multicast3">
<to
uri="seda:SEDA_TOP_102?size=100000&concurrentConsumers=10&waitForTaskToComplete=Never&failIfNoConsumers=true&timeout=10000"
id="to8"/>
<to
uri="seda:SEDA_ACK_103?size=100000&concurrentConsumers=10&waitForTaskToComplete=IfReplyExpected&failIfNoConsumers=true&timeout=10000"
customId="true" id="ROUTE_ID_RAW_DTC_EVENTS_TO_FIRST_URIS"/>
<setProperty propertyName="CamelCharsetName"
id="setProperty11">
<expressionDefinition>iso-8859-1</expressionDefinition>
</setProperty>
</multicast>
</threads>
</route>
*The stack trace:*
[2015-09-04 21:45:00,098] ERROR [Camel (MPLR_DTC) thread #94 - WireTap]
Failed delivery for (MessageId:
ID-talend-es-edge-01-kiad0-s-mission-net-35868-1441312070176-0-196157897 on
ExchangeId:
ID-talend-es-edge-01-kiad0-s-mission-net-35868-1441312070176-0-196157898).
Exhausted after delivery attempt: 1 caught:
java.nio.channels.ClosedChannelException
Message History
---------------------------------------------------------------------------------------------------------------------------------------
RouteId ProcessorId Processor
Elapsed (ms)
[ROUTE_ID_RAW_DTC_E] [ROUTE_ID_RAW_DTC_E]
[udp://talend-es-edge-01.kiad0.s.mission.net:62265 ] [
1]
[ROUTE_ID_RAW_DTC_E] [setProperty1 ] [setProperty[CamelCharsetName]
] [ 0]
[ROUTE_ID_RAW_DTC_E] [threads1 ] [threads
] [ 1]
[ROUTE_ID_RAW_DTC_E] [ROUTE_ID_RAW_DTC_E]
[wireTap[netty:udp://abinitio-edge-02.kiad0.s.mission.net:62265?clientPi] [
0]
Exchange
---------------------------------------------------------------------------------------------------------------------------------------
Exchange[
Id
ID-talend-es-edge-01-kiad0-s-mission-net-35868-1441312070176-0-196157898
ExchangePattern InOnly
Headers
{breadcrumbId=ID-talend-es-edge-01-kiad0-s-mission-net-35868-1441312070176-0-196157886,
CamelNettyChannelHandlerContext=org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext@3c6eb35b,
CamelNettyLocalAddress=/69.59.232.69:62265, CamelNettyMessageEvent=[id:
0xc66f8e56, /69.59.232.69:62265] RECEIVED: ÀË8mÄ- ½Uê ª from
/197.237.41.57:1036, CamelNettyRemoteAddress=/197.237.41.57:1036,
CamelRedelivered=false, CamelRedeliveryCounter=0}
BodyType String
Body ÀË8mÄ-½Uêª
]
Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
java.nio.channels.ClosedChannelException
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.cleanUpWriteBuffer(AbstractNioWorker.java:433)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.NioDatagramWorker.writeFromUserCode(NioDatagramWorker.java:212)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.NioDatagramPipelineSink.eventSunk(NioDatagramPipelineSink.java:97)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:779)
~[netty-3.9.6.Final.jar:?]
at org.jboss.netty.channel.Channels.write(Channels.java:725)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.doEncode(OneToOneEncoder.java:71)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:59)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:591)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:582)
~[netty-3.9.6.Final.jar:?]
at org.jboss.netty.channel.Channels.write(Channels.java:704)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.AbstractChannel.write(AbstractChannel.java:252)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.NioDatagramChannel.write(NioDatagramChannel.java:299)
~[netty-3.9.6.Final.jar:?]
at
org.apache.camel.component.netty.NettyHelper.writeBodyAsync(NettyHelper.java:93)
[camel-netty-2.15.2.jar:2.15.2]
at
org.apache.camel.component.netty.NettyProducer.process(NettyProducer.java:263)
[camel-netty-2.15.2.jar:2.15.2]
at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:448)
[camel-core-2.15.2.jar:2.15.2]
at
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
[camel-core-2.15.2.jar:2.15.2]
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:109)
[camel-core-2.15.2.jar:2.15.2]
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87)
[camel-core-2.15.2.jar:2.15.2]
at
org.apache.camel.processor.WireTapProcessor$1.call(WireTapProcessor.java:119)
[camel-core-2.15.2.jar:2.15.2]
at
org.apache.camel.processor.WireTapProcessor$1.call(WireTapProcessor.java:113)
[camel-core-2.15.2.jar:2.15.2]
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
[?:1.7.0_75]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
[?:1.7.0_75]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
[?:1.7.0_75]
at java.lang.Thread.run(Thread.java:745) [?:1.7.0_75]
[2015-09-04 21:45:02,532] WARN [New I/O worker #49] Caused by:
[org.apache.camel.CamelExchangeException - Cannot write response to
/188.122.39.102:0. Exchange[Message: ]. Caused by: [java.net.SocketException
- Invalid argument]]
org.apache.camel.CamelExchangeException: Cannot write response to
/188.122.39.102:0. Exchange[Message: ]. Caused by: [java.net.SocketException
- Invalid argument]
at
org.apache.camel.component.netty.handlers.ServerResponseFutureListener.operationComplete(ServerResponseFutureListener.java:53)
[camel-netty-2.15.2.jar:2.15.2]
at
org.jboss.netty.channel.DefaultChannelFuture.notifyListener(DefaultChannelFuture.java:431)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.DefaultChannelFuture.notifyListeners(DefaultChannelFuture.java:417)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.DefaultChannelFuture.setFailure(DefaultChannelFuture.java:384)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.NioDatagramWorker.write0(NioDatagramWorker.java:319)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.writeFromTaskLoop(AbstractNioWorker.java:151)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.AbstractNioChannel$WriteTask.run(AbstractNioChannel.java:335)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.processTaskQueue(AbstractNioSelector.java:391)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:315)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.NioDatagramWorker.run(NioDatagramWorker.java:343)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
[netty-3.9.6.Final.jar:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
[?:1.7.0_75]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
[?:1.7.0_75]
at java.lang.Thread.run(Thread.java:745) [?:1.7.0_75]
Caused by: java.net.SocketException: Invalid argument
at sun.nio.ch.DatagramChannelImpl.send0(Native Method) ~[?:1.7.0_75]
at
sun.nio.ch.DatagramChannelImpl.sendFromNativeBuffer(DatagramChannelImpl.java:532)
~[?:1.7.0_75]
at sun.nio.ch.DatagramChannelImpl.send(DatagramChannelImpl.java:494)
~[?:1.7.0_75]
at sun.nio.ch.DatagramChannelImpl.send(DatagramChannelImpl.java:473)
~[?:1.7.0_75]
at
org.jboss.netty.channel.socket.nio.SocketSendBufferPool$UnpooledSendBuffer.transferTo(SocketSendBufferPool.java:207)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.NioDatagramWorker.write0(NioDatagramWorker.java:281)
~[netty-3.9.6.Final.jar:?]
... 11 more
[2015-09-04 21:45:02,535] WARN [pool-17-thread-23] Closing channel as
an exception was thrown from Netty. Caused by: [java.net.SocketException -
Invalid argument]
java.net.SocketException: Invalid argument
at sun.nio.ch.DatagramChannelImpl.send0(Native Method) ~[?:1.7.0_75]
at
sun.nio.ch.DatagramChannelImpl.sendFromNativeBuffer(DatagramChannelImpl.java:532)
~[?:1.7.0_75]
at sun.nio.ch.DatagramChannelImpl.send(DatagramChannelImpl.java:494)
~[?:1.7.0_75]
at sun.nio.ch.DatagramChannelImpl.send(DatagramChannelImpl.java:473)
~[?:1.7.0_75]
at
org.jboss.netty.channel.socket.nio.SocketSendBufferPool$UnpooledSendBuffer.transferTo(SocketSendBufferPool.java:207)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.NioDatagramWorker.write0(NioDatagramWorker.java:281)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.writeFromTaskLoop(AbstractNioWorker.java:151)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.AbstractNioChannel$WriteTask.run(AbstractNioChannel.java:335)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.processTaskQueue(AbstractNioSelector.java:391)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:315)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.channel.socket.nio.NioDatagramWorker.run(NioDatagramWorker.java:343)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
~[netty-3.9.6.Final.jar:?]
at
org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
~[netty-3.9.6.Final.jar:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
[?:1.7.0_75]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
[?:1.7.0_75]
at java.lang.Thread.run(Thread.java:745) [?:1.7.0_75]
--
View this message in context:
http://camel.465427.n5.nabble.com/CamelCamel-2-15-2-ExchangeException-Cannot-write-response-tp5771341.html
Sent from the Camel - Users mailing list archive at Nabble.com.
