activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From artnaseef <...@artnaseef.com>
Subject Re: Hung Producer
Date Tue, 18 Feb 2014 16:01:43 GMT
Inactivity errors (InactivityIOException) like that point to either a very large network delay
or a very slow JVM - either broker or client. 

When running the test, how does the GC activity, CPU and memory on the JVM for the broker
and client look?

Sent from my iPhone

> On Feb 18, 2014, at 1:43 AM, "Ashwini Kuntamukkala [via ActiveMQ]" <ml-node+s2283324n4678063h1@n4.nabble.com>
wrote:
> 
> I repeated the test with the following settings 
> 
> activemq.xml openwire transport connector 
> 
> <transportConnector name="openwire" uri="nio://0.0.0.0:61616?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600&amp;useQueueForAccept=false&amp;wireFormat.maxInactivityDuration=0&amp;transport.socketBufferSize=131072&amp;transport.ioBufferSize=65536&amp;transport.soTimeout=10000&amp;transport.soWriteTimeout=15000"/>
> 
> Client URL 
> broker.url=tcp://broker-machine:61616?jms.useAsyncSend=false&soWriteTimeout=15000

> 
> This time the producers crash with the following exception 
> 
> [WARNING] 
> org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during
JMS processing; nested exception is javax.jms.JMSException: Cannot send, channel has already
failed: tcp://broker-machine:61616 
>         at org.springframework.jms.support.JmsUtils.convertJmsAccessException(Jm 
> sUtils.java:316) 
>         at org.springframework.jms.support.JmsAccessor.convertJmsAccessException 
> (JmsAccessor.java:168) 
>         at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:469 
> ) 
>         at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:543) 
>         at producer.ProducerTask.run(ProducerTask.java:43) 
>         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)

>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)

>         at java.lang.Thread.run(Thread.java:744)Caused by: javax.jms.JMSException: Cannot
send, channel has already failed: tcp: 
> //broker-machine:61616 
>         at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)

>         at org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1306)

>         at org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1298)

>         at org.apache.activemq.ActiveMQSession.<init>(ActiveMQSession.java:252)

>         at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:334)

>         at org.apache.activemq.pool.ConnectionPool$2.makeObject(ConnectionPool.java:105)

>         at org.apache.activemq.pool.ConnectionPool$2.makeObject(ConnectionPool.java:90)

>         at org.apache.commons.pool.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:1220)

>         at org.apache.activemq.pool.ConnectionPool.createSession(ConnectionPool.java:142)

>         at org.apache.activemq.pool.PooledConnection.createSession(PooledConnection.java:174)

>         at org.springframework.jms.support.JmsAccessor.createSession(JmsAccessor.java:196)

>         at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:457) 
>         ... 5 more 
> Caused by: org.apache.activemq.transport.InactivityIOException: Cannot send, cha 
> nnel has already failed: tcp://10.12.44.82:61616 
>         at org.apache.activemq.transport.AbstractInactivityMonitor.doOnewaySend(AbstractInactivityMonitor.java:315)
>         at org.apache.activemq.transport.AbstractInactivityMonitor.oneway(AbstractInactivityMonitor.java:304)

>         at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85)

>         at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104)

>         at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85)

>         at org.apache.activemq.transport.WriteTimeoutFilter.oneway(WriteTimeoutFilter.java:73)

>         at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)

>         at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)

>         at org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1304)

> 
> If you reply to this email, your message will be added to the discussion below:
> http://activemq.2283324.n4.nabble.com/Hung-Producer-tp4678060p4678063.html
> To start a new topic under ActiveMQ - Dev, email ml-node+s2283324n2368404h72@n4.nabble.com

> To unsubscribe from ActiveMQ - Dev, click here.
> NAML




--
View this message in context: http://activemq.2283324.n4.nabble.com/Hung-Producer-tp4678060p4678093.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message