activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gaurav Hariani <gau...@blackspark.com>
Subject Re: Single Producer waiting on send
Date Fri, 30 Mar 2007 18:13:09 GMT
Would this show up in the memory usage on the broker?
Yesterday we experienced this problem again .... the producer blocked 
for 22 hours this time.
The messages are all very small 200 bytes each and one message is sent 
every 5-6 seconds.





James Strachan wrote:
> You might be hitting this...
>
> http://activemq.apache.org/my-producer-blocks.html
>
> On 3/27/07, Gaurav Hariani <gaurav@blackspark.com> wrote:
>> I have a single producer (Java) that sends small messages to about 20
>> consumers (written in C#).
>> After a few hours of running it blocks for many hours on the send.
>> What could be causing this?
>>
>> "main" prio=6 tid=0x00286000 nid=0xe3c in Object.wait() 
>> [0x0090f000..0x0090fe58]
>>
>>    java.lang.Thread.State: WAITING (on object monitor)
>>
>>         at java.lang.Object.wait(Native Method)
>>
>>         at java.lang.Object.wait(Object.java:485)
>>
>>         at 
>> edu.emory.mathcs.backport.java.util.concurrent.locks.CondVar.await(CondVar.java:75)

>>
>>
>>         - locked <0x2293cf58> (a 
>> edu.emory.mathcs.backport.java.util.concurrent.locks.CondVar)
>>
>>         at 
>> edu.emory.mathcs.backport.java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:318)

>>
>>
>>         at 
>> org.apache.activemq.transport.FutureResponse.getResult(FutureResponse.java:42) 
>>
>>
>>         at 
>> org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:75)

>>
>>
>>         at 
>> org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1171)

>>
>>
>>         at 
>> org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1548)
>>
>>         at 
>> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:465)

>>
>>
>>         at 
>> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:356)

>>
>>
>>         at MainClass.sendMessage(MainClass.java:185)
>>
>>
>
>


Mime
View raw message