You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ac...@apache.org on 2005/12/27 02:11:52 UTC

svn commit: r359152 - /incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/PrefetchSubscription.java

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() ) {