Details
-
Bug
-
Resolution: Obsolete
-
Major
-
None
-
None
-
None
-
None
Description
Actually found during kit testing of 08-04.
1. Start fresh database. Using default broker config with limits changed, I used 50MB ( <tempUsage limit="50 mb"/>)
2. start producer, i.e
wildflower:example sjavurek$ ant producer -DparallelThreads=5 -DmessageSize=5120 -Dmax=10000 Buildfile: /Users/sjavurek/Fuse/activemq/RC/apache-activemq-5.5.1-fuse-08-04/example/build.xml init: compile: producer: [echo] Running producer against server at $url = tcp://localhost:61616 for subject $subject = TEST.FOO [java] Connecting to URL: tcp://localhost:61616 (:) [java] Publishing a Message with size 5120 to queue: TEST.FOO [java] Using non-persistent messages [java] Sleeping between publish 0 ms [java] Running 5 parallel threads [java] [Thread-6] Sending message: 'Message: 0 sent at: Fri Aug 17 13:21:46 EDT 2012 ...' [java] [Thread-3] Sending message: 'Message: 0 sent at: Fri Aug 17 13:21:46 EDT 2012 ...'
3. Carries on until PFC kicks in.
4. I start a consumer to try to remove messages and it just hangs. Coincidentally my jconsole window looses it's view of all the attributes including when I click on the broker. Can't shut it down cleanly either as someone is hung up:
INFO | The connection to 'tcp://127.0.0.1:63148' is taking a long time to shutdown.
Appears to be the producer and I can kill it:
etswildflower:~ sjavurek$ netstat -a |grep 63148 tcp4 65536 0 Susan-Javureks-M.61616 Susan-Javureks-M.63148 ESTABLISHED tcp4 0 63889 Susan-Javureks-M.63148 Susan-Javureks-M.61616 ESTABLISHED wildflower:~ sjavurek$ netstat -a |grep 63148 wildflower:~ sjavurek$
But then broker just hangs. I eventually kill -9 it.
The windows side exhibits but result is same, can't pull messages off the queue at this point. There are actually wire format errors:
consumer: [echo] Running consumer against server at $url = tcp://localhost:61616 for subject $subject = TEST.FOO [java] Connecting to URL: tcp://localhost:61616 (:) [java] Consuming queue: TEST.FOO [java] Using a non-durable subscription [java] Running 1 parallel threads [java] javax.jms.JMSException: Wire format negotiation timeout: peer did not send his wire format. [java] at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) [java] at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1316) [java] at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1402) [java] at org.apache.ac[Thread-2] Caught: javax.jms.JMSException: Wire format negotiation timeout: peer did not send his wire format. [java] tivemq.ActiveMQConnection.start(ActiveMQConnection.java:507) [java] at ConsumerTool.run(Unknown Source) [java] Caused by: java.io.IOException: Wire format negotiation timeout: peer did not send his wire format. [java] at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:98) [java] at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68) [java] at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81) [java] at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86) [java] at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1287) [java] ... 3 more [java] All threads completed their work
And the producer actually falls over:
consumer: [echo] Running consumer against server at $url = tcp://localhost:61616 for subject $subject = TEST.FOO [java] Connecting to URL: tcp://localhost:61616 (:) [java] Consuming queue: TEST.FOO [java] Using a non-durable subscription [java] Running 1 parallel threads [java] javax.jms.JMSException: Wire format negotiation timeout: peer did not send his wire format. [java] at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) [java] at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1316) [java] at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1402) [java] at org.apache.ac[Thread-2] Caught: javax.jms.JMSException: Wire format negotiation timeout: peer did not send his wire format. [java] tivemq.ActiveMQConnection.start(ActiveMQConnection.java:507) [java] at ConsumerTool.run(Unknown Source) [java] Caused by: java.io.IOException: Wire format negotiation timeout: peer did not send his wire format. [java] at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:98) [java] at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68) [java] at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81) [java] at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86) [java] at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1287) [java] ... 3 more [java] All threads completed their work
I had a _quick_ look in JIRA and didn't see anything.
Note, didn't take any thread dumps or anything - really need to get to some other issues today but can circle back around later if need be.