Re: NEED HELP: Exchanges remain inflight on route with recipientList() or toD()

[SteveR <sr...@vonage.com>]

This problem is severe enough to cause my Camel application to exhaust
resources (e.g. number of open files) which results in major application
failure.  Below are some of the errors and stack trace that I get when
sending in only 4000 messages using a Java UDP sender test program.

I've worked pretty hard, so far, trying to learn Camel and standing up this
UDP routing application. Everything else seems to be working just fine (e.g.
UDP receive, producing to kafka, creating backup files, throughput logging,
etc).  This route that deals with sending a UDP acknowledgement is the only
part that is causing issues. I would hate to give up now over an issue like
this, but I'm running out of ideas and my management is getting impatient
and a jaded view of Apache Camel.  It was my idea to use Camel, so I'm
trying real hard to make it work successfully.

   Thanks, SteveR

    [2015-10-26 21:08:05,451 UTC] *ERROR *[Camel (MPLR_CQMS) thread #40 -
seda://SEDA_ACK_103] [FailureEventNotifier:notify:63]: Exchange failed:
exchangeId =
ID-talend-es-01-dloco-m-mission-net-32956-1445893522490-0-51974, fromRouteId
= ROUTE_ID_RAW_CQMS_EVENTS_SEDA_ACK, route =
EventDrivenConsumerRoute[Endpoint[seda://SEDA_ACK_103?concurrentConsumers=10&size=200000]
-> Pipeline[[Channel[SetExchangePattern[InOnly]],
Channel[SetProperty(CamelCharsetName, iso-8859-1)],
Channel[DelegateSync[com.mission.mplr.multiprotocollistenerrouter.CqmsAckBackProcessor@3563739]],
Channel[sendTo(netty:udp://${header.REMOTE_HOST_IP}:${header.REMOTE_PORT_NUMBER}?clientPipelineFactory=#CQMS_CLIENT_PIPELINE_FACTORY_ROUTE_ID_RAW_CQMS_EVENTS&sendBufferSize=26214400&allowDefaultCodec=false)],
Channel[Stop]]]], *exceptionMsg = Failed to open a DatagramChannel.*


    [2015-10-26 21:09:37,663] *WARN 
*[qtp2066624561-39-acceptor-0@1b7d21a5-ServerConnector@5dcdfc98{HTTP/1.1}{talend-es-01.dloco.m.mission.net:8090}]
	*java.io.IOException: Too many open files*
			at sun.nio.ch.ServerSocketChannelImpl.accept0(Native Method)
~[?:1.7.0_75]
			at
sun.nio.ch.ServerSocketChannelImpl.accept(ServerSocketChannelImpl.java:241)
~[?:1.7.0_75]
			at
org.eclipse.jetty.server.ServerConnector.accept(ServerConnector.java:377)
~[jetty-server-9.2.11.v20150529.jar:9.2.11.v20150529]
			at
org.eclipse.jetty.server.AbstractConnector$Acceptor.run(AbstractConnector.java:500)
[jetty-server-9.2.11.v20150529.jar:9.2.11.v20150529]
			at
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:635)
[jetty-util-9.2.11.v20150529.jar:9.2.11.v20150529]
			at
org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:555)
[jetty-util-9.2.11.v20150529.jar:9.2.11.v20150529]
			at java.lang.Thread.run(Thread.java:745) [?:1.7.0_75]



--
View this message in context: http://camel.465427.n5.nabble.com/NEED-HELP-Exchanges-remain-inflight-on-route-with-recipientList-or-toD-tp5773079p5773081.html
Sent from the Camel - Users mailing list archive at Nabble.com.