mirror of https://github.com/apache/activemq.git
fixed typeo and made synchronized collection private
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390149 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
d9729e86d4
commit
217e0c8527
|
@ -60,7 +60,7 @@ public class Queue implements Destination {
|
|||
|
||||
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 class Queue implements Destination {
|
|||
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="
|
||||
|
|
Loading…
Reference in New Issue