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