activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cepo...@apache.org
Subject svn commit: r1418378 - /activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java
Date Fri, 07 Dec 2012 16:19:09 GMT
Author: ceposta
Date: Fri Dec  7 16:19:08 2012
New Revision: 1418378

URL: http://svn.apache.org/viewvc?rev=1418378&view=rev
Log:
Fix for https://issues.apache.org/jira/browse/AMQ-4190 - Figure out what was intended with
transactions and producer flow control for topics

Fix the counter so the logging happens

Modified:
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java?rev=1418378&r1=1418377&r2=1418378&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java
Fri Dec  7 16:19:08 2012
@@ -404,6 +404,7 @@ public class Topic extends BaseDestinati
                                     LOG.warn("Waiting for space to send  transacted message
- transaction elements = "
                                             + size + " need more space to commit. Message
= " + message);
                                 }
+                                count++;
                             }
                         } else {
                             waitForSpace(



Mime
View raw message