[hornetq-commits] JBoss hornetq SVN: r11485 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at 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);
       }
    }