[hornetq-commits] JBoss hornetq SVN: r11485 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl.
Author: clebert.suconic(a)jboss.com
Date: 2011-10-06 16:58:53 -0400 (Thu, 06 Oct 2011)
New Revision: 11485
Modified:
branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/QueueImpl.java
Log:
tweak: removing dead code
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/QueueImpl.java
===================================================================
---
branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/QueueImpl.java 2011-10-06
20:57:38 UTC (rev 11484)
+++
branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/QueueImpl.java 2011-10-06
20:58:53 UTC (rev 11485)
@@ -122,7 +122,6 @@
// The estimate of memory being consumed by this queue. Used to calculate instances of
messages to depage
private final AtomicInteger queueMemorySize = new AtomicInteger(0);
- private final AtomicInteger queueInstances = new AtomicInteger(0);
private final List<ConsumerHolder> consumerList = new
ArrayList<ConsumerHolder>();
@@ -462,14 +461,14 @@
{
if (isTrace)
{
- log.trace("Force delivery scheduling depage");
+ log.trace("Force delivery scheduling depage");
}
scheduleDepage();
}
if (isTrace)
{
- log.trace("Force delivery deliverying async");
+ log.trace("Force delivery deliverying async");
}
deliverAsync();
@@ -2256,7 +2255,7 @@
}
catch (Exception e)
{
- QueueImpl.log.warn("Unable to decrement reference counting", e);
+ QueueImpl.log.warn("Unable to decrement reference counting", e);
}
}