[hornetq-commits] JBoss hornetq SVN: r7958 - trunk/src/main/org/hornetq/core/management/impl.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2009-09-15 09:20:48 -0400 (Tue, 15 Sep 2009)
New Revision: 7958

Modified:
   trunk/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java
Log:
Message Counter configuration

* removed messageCounterEnable attribute from HornetQServerControlImpl and
  delegates to the configuration's attribute instead

Modified: trunk/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java	2009-09-15 12:17:22 UTC (rev 7957)
+++ trunk/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java	2009-09-15 13:20:48 UTC (rev 7958)
@@ -82,8 +82,6 @@
 
    private final NotificationBroadcasterSupport broadcaster;
 
-   private boolean messageCounterEnabled;
-
    // Static --------------------------------------------------------
 
    // Constructors --------------------------------------------------
@@ -103,7 +101,6 @@
       this.server = messagingServer;
       this.messageCounterManager = messageCounterManager;
       this.broadcaster = broadcaster;
-      this.messageCounterEnabled = configuration.isMessageCounterEnabled();
    }
 
    // Public --------------------------------------------------------
@@ -314,7 +311,7 @@
 
    public boolean isMessageCounterEnabled()
    {
-      return messageCounterEnabled;
+      return configuration.isMessageCounterEnabled();
    }
 
    public synchronized long getMessageCounterSamplePeriod()
@@ -564,16 +561,16 @@
    {
       if (isStarted())
       {
-         if (messageCounterEnabled && !enable)
+         if (configuration.isMessageCounterEnabled() && !enable)
          {
             stopMessageCounters();
          }
-         else if (!messageCounterEnabled && enable)
+         else if (!configuration.isMessageCounterEnabled() && enable)
          {
             startMessageCounters();
          }
       }
-      messageCounterEnabled = enable;
+      configuration.setMessageCounterEnabled(enable);
    }
 
    private void startMessageCounters()