camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: Camel 1.6/2.0 MINA UDP issue
Date Thu, 12 Mar 2009 16:47:06 GMT
On Thu, Mar 12, 2009 at 5:31 PM, orton <o_huang@yahoo.com> 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 <claus.ibsen@gmail.com>
>> 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 <o_huang@yahoo.com> 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/

Mime
View raw message