activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Viktor Matic (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 Sun, 02 Nov 2008 11:31:05 GMT

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

Viktor Matic commented on AMQ-1992:
-----------------------------------

The same BUG can be reproduced if AMQ is configured without journal and with JDBCPersistenceAdaptor.
I've reproduced it with postgres JDBC.

If  JDBCPersistenceAdaptor is used in combination with journal, AMQ allows queuing of new
28 messages after every restart. Which is also wrong because messages are accumulated with
each AMQ restart. This behavior is different then previously described case in which flow
control allows infinite queuing after first restart.  Also I have checked table activemq_msgs
in postgres and found that messages are really persisted and accumulated after first restart.
 

> 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