activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Josip Gracin (JIRA)" <j...@apache.org>
Subject [jira] Commented: (AMQ-1992) flow control doesn't work after first restart (if producer works in transacted mode with persistent messages)
Date Mon, 03 Nov 2008 10:05:05 GMT

    [ https://issues.apache.org/activemq/browse/AMQ-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=46985#action_46985
] 

Josip Gracin commented on AMQ-1992:
-----------------------------------

Adding a bit to this report... The problem seems to be related to the fact that we're using
persistent messages.  Furthermore, with persistent messages, we're getting (easily reproducible)
lock-ups of producers.  When a producer gets throttled back by flow control, it ends up in
waitForSpace() and it never returns (despite of consuming all the messages in its queue).

> flow control doesn't work after first restart (if producer works in transacted mode with
persistent messages)
> -------------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1992
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1992
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.1.0, 5.2.0
>         Environment: Intel MAC OSX Java (build 1.5.0_16-b06-284)
>            Reporter: Viktor Matic
>
> To reproduce BUG follow instructions:
> 1. Unpack fresh AMQ (versions 5.1.0, 5.2.0, 5.3.0-SNAPSHOT)
> 2. Edit $AMQ_HOME/examples/ProducerTool.java turn on transacted mode and persisting messages.

> (I have modified source code directly because I couldn't change this parameters through
build.xml. Change is simple.)
> Patch:
> 78,79d77
> <             transacted = true;
> < 
> 88,89d85
> <             persistent = true;
> < 
> 3. Start AMQ $AMQ_HOME/bin/activemq
> 4. Start producer $AMQ_HOME/examples/ant producer -DmessageSize=200000
> 5. Producer will block (on commit method) after approximately 27 messages (which is OK
for selected message size and default max queues size 5Mb)
> 6. Stop producer and AMQ in any order (CTRL-C in terminal)
> 7. Start AMQ  $AMQ_HOME/bin/activemq
> 8. Start producer $AMQ_HOME/examples/ant producer -DmessageSize=200000
> Producer will continue to queue messages infinitely.

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