activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ashwini Kuntamukkala <akuntamukk...@gmail.com>
Subject Re: Hung Producer
Date Tue, 18 Feb 2014 08:43:24 GMT
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)



--
View this message in context: http://activemq.2283324.n4.nabble.com/Hung-Producer-tp4678060p4678063.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.

Mime
View raw message