From 720a19c5bf93c952d97312e41c05d25d02c48f84 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Fri, 5 Jan 2007 11:47:49 +0000 Subject: [PATCH] optimization for large number of queue consumers git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492993 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/activemq/broker/region/IndirectMessageReference.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java index 1d03c03624..8c06130cc9 100644 --- a/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java @@ -110,7 +110,7 @@ public class IndirectMessageReference implements QueueMessageReference { int rc = --referenceCount; if( persistent && rc == 0 && message!=null) { message.decrementReferenceCount(); - message=null; + //message=null; } return rc; }