activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Filip Hanik (JIRA)" <j...@apache.org>
Subject [jira] Commented: (AMQ-1557) High message frequency causes ActiveMQ to freeze
Date Tue, 29 Apr 2008 16:17:43 GMT

    [ 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.


Mime
View raw message