Return-Path: X-Original-To: apmail-activemq-dev-archive@www.apache.org Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CDAA910F30 for ; Wed, 19 Feb 2014 08:40:09 +0000 (UTC) Received: (qmail 61242 invoked by uid 500); 19 Feb 2014 08:40:09 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 60948 invoked by uid 500); 19 Feb 2014 08:40:06 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 60935 invoked by uid 99); 19 Feb 2014 08:40:01 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 19 Feb 2014 08:40:01 +0000 X-ASF-Spam-Status: No, hits=2.3 required=5.0 tests=SPF_SOFTFAIL,URI_HEX X-Spam-Check-By: apache.org Received-SPF: softfail (nike.apache.org: transitioning domain of akuntamukkala@gmail.com does not designate 216.139.236.26 as permitted sender) Received: from [216.139.236.26] (HELO sam.nabble.com) (216.139.236.26) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 19 Feb 2014 08:39:56 +0000 Received: from joe.nabble.com ([192.168.236.139]) by sam.nabble.com with esmtp (Exim 4.72) (envelope-from ) id 1WG2go-0007La-Sc for dev@activemq.apache.org; Wed, 19 Feb 2014 00:39:35 -0800 Date: Wed, 19 Feb 2014 00:39:34 -0800 (PST) From: Ashwini Kuntamukkala To: dev@activemq.apache.org Message-ID: <1392799174875-4678114.post@n4.nabble.com> In-Reply-To: <1392750127520-4678103.post@n4.nabble.com> References: <1392707756987-4678060.post@n4.nabble.com> <1392713004443-4678063.post@n4.nabble.com> <899C401E-146D-427D-B347-3BBCAD1628B8@artnaseef.com> <1392750127520-4678103.post@n4.nabble.com> Subject: Re: Hung Producer MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org 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.