activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Torsten Mielke <tmie...@redhat.com>
Subject Re: Hung Producer
Date Wed, 19 Feb 2014 10:01:27 GMT
Is your producer getting flow controlled? 
Does your broker reach any of its configured systemUsage limits? 
Broker JMX stats should tell you. Particularly check MemoryPercentUsage, StorePercentUsage
and TempPercentUsage of the broker MBean.


Regards,

Torsten Mielke
tmielke.blogspot.com


On 19 Feb 2014, at 09:39 am, Ashwini Kuntamukkala <akuntamukkala@gmail.com> wrote:

> Repeated the test with refactored project with 100 producers sharing same jms
> template which is configured to use cached connection factory. After several
> 1,000,000s of messages in 60+ minutes, the producers hang with following
> exception.  
> 
> Name: producerTaskExecutor-27
> State: RUNNABLE
> Total blocked: 2  Total waited: 4,926
> 
> Stack trace: 
> java.net.SocketOutputStream.socketWrite0(Native Method)
> java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:113)
> java.net.SocketOutputStream.write(SocketOutputStream.java:159)
> org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:115)
> java.io.DataOutputStream.flush(DataOutputStream.java:123)
> org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:176)
> org.apache.activemq.transport.AbstractInactivityMonitor.doOnewaySend(AbstractInactivityMonitor.java:322)
> org.apache.activemq.transport.AbstractInactivityMonitor.oneway(AbstractInactivityMonitor.java:304)
> org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85)
> org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104)
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
> org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1304)
> org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1298)
> org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1782)
>   - locked java.lang.Object@5229aec6
> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:289)
> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:224)
> org.apache.activemq.ActiveMQMessageProducerSupport.send(ActiveMQMessageProducerSupport.java:269)
> org.springframework.jms.connection.CachedMessageProducer.send(CachedMessageProducer.java:121)
> org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:589)
> org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:569)
> org.springframework.jms.core.JmsTemplate$4.doInJms(JmsTemplate.java:546)
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)
> org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:543)
> producer.ProducerTask.run(ProducerTask.java:43)
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> java.lang.Thread.run(Thread.java:744)
> 
> 
> 
> 
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Hung-Producer-tp4678060p4678114.html
> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.





Mime
View raw message