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]" 
> <[email protected]> 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 
> [email protected] 
> 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.

Reply via email to