[hornetq-commits] JBoss hornetq SVN: r7958 - trunk/src/main/org/hornetq/core/management/impl.
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()