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()