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); } }