You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/03/30 16:37:24 UTC
svn commit: r390149 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
Author: jstrachan
Date: Thu Mar 30 06:37:24 2006
New Revision: 390149
URL: http://svn.apache.org/viewcvs?rev=390149&view=rev
Log:
fixed typeo and made synchronized collection private
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java?rev=390149&r1=390148&r2=390149&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java Thu Mar 30 06:37:24 2006
@@ -60,7 +60,7 @@
protected final ActiveMQDestination destination;
protected final List consumers = new CopyOnWriteArrayList();
- protected final LinkedList messages = new LinkedList();
+ private final LinkedList messages = new LinkedList();
protected final Valve dispatchValve = new Valve(true);
protected final UsageManager usageManager;
protected final DestinationStatistics destinationStatistics = new DestinationStatistics();
@@ -330,7 +330,7 @@
public String toString() {
int size = 0;
synchronized (messages) {
- size = message.size();
+ size = messages.size();
}
return "Queue: destination=" + destination.getPhysicalName() + ", subscriptions=" + consumers.size()
+ ", memory=" + usageManager.getPercentUsage() + "%, size=" + size + ", in flight groups="