activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a..@apache.org
Subject svn commit: r359152 - /incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/PrefetchSubscription.java
Date Tue, 27 Dec 2005 01:11:52 GMT
Author: aco
Date: Mon Dec 26 17:11:43 2005
New Revision: 359152

URL: http://svn.apache.org/viewcvs?rev=359152&view=rev
Log:
Rollback changes to incrementReferenceCount, but maintained the incrementPreloadSize

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/PrefetchSubscription.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/PrefetchSubscription.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/PrefetchSubscription.java?rev=359152&r1=359151&r2=359152&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/PrefetchSubscription.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/PrefetchSubscription.java
Mon Dec 26 17:11:43 2005
@@ -238,6 +238,7 @@
     }
 
     private void dispatch(final MessageReference node) throws IOException {
+        node.incrementReferenceCount();
         
         final Message message = node.getMessage();
         if( message == null ) {
@@ -250,7 +251,6 @@
             MessageDispatch md = createMessageDispatch(node, message);
             dispatched.addLast(node);
             
-            node.incrementReferenceCount();
             incrementPreloadSize(node.getMessage().getSize()); 
             
             if( info.isDispatchAsync() ) {



Mime
View raw message