On Thu, Mar 12, 2009 at 5:31 PM, orton <[email protected]> wrote: > > Hi Again, > > Thanks Claus for the fix! That resolved the issue I was having with the MINA > sender and I can run it a lot longer. > > Unfortunately :( however, I get this problem now after many more messages: > > Messages Sent: [Publisher]: Test Body Message: 2366999 > Messages Sent: [Publisher]: Test Body Message: 2367999 > Messages Sent: [Publisher]: Test Body Message: 2368999 > Exception caught: Cannot write body on the exchange: Exchange[Message: > [Publisher]: Test Body Message: 2369836] > org.apache.camel.CamelExchangeException: Cannot write body on the exchange: > Exchange[Message: [Publisher]: Test Body Message: 2369836] > at > org.apache.camel.component.mina.MinaHelper.writeBody(MinaHelper.java:52) > at > org.apache.camel.component.mina.MinaProducer.process(MinaProducer.java:99) > at > edu.mit.ll.test.clients.UDPCamelClient.sendMessages(UDPCamelClient.java:70) > at edu.mit.ll.test.clients.UDPCamelClient.main(UDPCamelClient.java:133) > > In this case, I'm sending 30 Byte messages one after another as fast as I > can and it gets to 2.3 million messages or so. I'm not sure if I'm running > out of memory (perhaps the garbage collection is cleaning up things fast > enough)? > > Thoughts? Thanks again! You should just catch the exception and continue with sending. It should be able to send the rest. Eg you can do a retry to send it again.
You are using UDP so the QoS is not as high as TCP. > > Claus Ibsen-2 wrote: >> >> Hi >> >> Just for the good sake. We have identified an issue and fixed it in >> camel-mina on trunk. >> >> Thanks to Orton for providing a sample case that surfaced the issue. >> Now it works like a charm and doesnt stall using UDP. >> >> >> On Wed, Mar 11, 2009 at 10:05 AM, Claus Ibsen <[email protected]> >> wrote: >>> Hi >>> >>> Can you create a zip with a sample project that demonstrates this issue? >>> I would like to take a look. >>> >>> Its interresting that creating a new producer once in a while resolves >>> it. eg you get a brand new MINA session to work with. >>> >>> >>> On Tue, Mar 10, 2009 at 8:01 PM, orton <[email protected]> wrote: >>>> >>>> One more thing... >>>> >>>> Right now, I'm just catching all Exceptions and printing them out. When >>>> the >>>> component stops sending, usually no exceptions are thrown... Not sure if >>>> they are getting swallowed up somewhere lower. >>>> >>>> However, one time I ran it, for some reason I did get this: >>>> >>>> Exception caught: Could not write body on the exchange: >>>> Exchange[Message: >>>> [Publisher]: Test Body Message: 34535] >>>> org.apache.camel.CamelExchangeException: Could not write body on the >>>> exchange: Exchange[Message: [Publisher]: Test Body Message: 34535] >>>> at >>>> org.apache.camel.component.mina.MinaHelper.writeBody(MinaHelper.java:47) >>>> at >>>> org.apache.camel.component.mina.MinaProducer.process(MinaProducer.java:99) >>>> at >>>> edu.mit.ll.test.clients.UDPCamelClient.sendMessages(UDPCamelClient.java:70) >>>> at >>>> edu.mit.ll.test.clients.UDPCamelClient.main(UDPCamelClient.java:84) >>>> -- >>>> View this message in context: >>>> http://www.nabble.com/Camel-1.6-2.0-MINA-UDP-issue-tp22426433p22441278.html >>>> Sent from the Camel - Development (activemq) mailing list archive at >>>> Nabble.com. >>>> >>>> >>> >>> >>> >>> -- >>> Claus Ibsen >>> Apache Camel Committer >>> >>> Open Source Integration: http://fusesource.com >>> Blog: http://davsclaus.blogspot.com/ >>> >> >> >> >> -- >> Claus Ibsen >> Apache Camel Committer >> >> Open Source Integration: http://fusesource.com >> Blog: http://davsclaus.blogspot.com/ >> >> > > -- > View this message in context: > http://www.nabble.com/Camel-1.6-2.0-MINA-UDP-issue-tp22426433p22479515.html > Sent from the Camel - Development (activemq) mailing list archive at > Nabble.com. > > -- Claus Ibsen Apache Camel Committer Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/
