[
https://issues.apache.org/activemq/browse/AMQ-1557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=42493#action_42493
]
Filip Hanik commented on AMQ-1557:
----------------------------------
I'm able to consistently reproduce the error with 5.0.0 and 5.1.0
I haven't been able to try it out trunk, since it doesn't build when I check it
out.
java.lang.OutOfMemoryError: Java heap space
Dumping heap to java_pid3448.hprof ...
Heap dump file created [212044211 bytes in 14.203 secs]
Exception in thread "ActiveMQ Transport: tcp:///127.0.0.1:1206"
java.lang.OutOfMemoryError: Java heap space
at
org.apache.activemq.openwire.v3.BaseDataStreamMarshaller.tightUnmarshalByteSequence(BaseDataStreamMarshaller.
java:441)
at
org.apache.activemq.openwire.v3.MessageMarshaller.tightUnmarshal(MessageMarshaller.java:68)
at
org.apache.activemq.openwire.v3.ActiveMQMessageMarshaller.tightUnmarshal(ActiveMQMessageMarshaller.java:67)
at
org.apache.activemq.openwire.v3.ActiveMQTextMessageMarshaller.tightUnmarshal(ActiveMQTextMessageMarshaller.ja
va:67)
at
org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:361)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:275)
at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:192)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
at java.lang.Thread.run(Thread.java:595)
Here is the info
1. Configuration file
http://people.apache.org/~fhanik/activemq.xml
2. Modified example code
http://people.apache.org/~fhanik/example.zip
Steps to reproduce
1. Apply the activemq.xml file
2. start the activemq server
3. start the consumer 'ant consumer' in the example directory (from example.zip)
4. start the producer 'ant producer' in the example directory (from
example.zip)
Just sit and watch, eventually it starts slowing down, and finally it throws an
OutOfMemoryError
As long as the consumer is connected, it's not skipping or discarding any
messages.
I was expecting the consumer to receive only the latst, but as long as the
consumer is connected, not a single message gets discarded, or at least it
appears that way, until the server runs out of java heap.
Filip
> High message frequency causes ActiveMQ to freeze
> ------------------------------------------------
>
> Key: AMQ-1557
> URL: https://issues.apache.org/activemq/browse/AMQ-1557
> Project: ActiveMQ
> Issue Type: Bug
> Affects Versions: 5.0.0, 5.1.0
> Environment: observed on Windows XP Professional SP2, Sun JDK
> 1.5.01_11, but probably affects all platforms
> Reporter: Jürgen Schumacher
> Assignee: Rob Davies
> Attachments: stresstest.zip
>
>
> ActiveMQ freezes in a test setup with very high message frequency of
> persistent messages and multiple producers and consumers running on multiple
> machines:
> - Host 1: Multiple Producers send messages very fast to queue1
> - Host 2: Multiple Processors consume message from queue1 and send a new
> message for each consumed message to queue2, also very fast.
> - Host 3: ActiveMQ server and 1 consumer reads messages from queue2.
> With producerFlowControl enabled, the system freezes very soon (a bit more
> than 1000 messages).
> With producerFlowControl disabled, it seems to run longer at first, but it
> still freezes later.
> Using transactions or not does not seem to make a difference.
> See this thread in user mailing list for more details:
> http://www.nabble.com/High-message-frequency-causes-ActiveMQ-to-freeze-to14919292s2354.html
> See attachment for code of test cases and the batch files to start them.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
