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