http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AdminDistributedSystemJmxImpl.java
----------------------------------------------------------------------
diff --git 
a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AdminDistributedSystemJmxImpl.java
 
b/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AdminDistributedSystemJmxImpl.java
deleted file mode 100755
index 5ff4bfa..0000000
--- 
a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AdminDistributedSystemJmxImpl.java
+++ /dev/null
@@ -1,2291 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.geode.admin.jmx.internal;
-
-import org.apache.geode.DataSerializer;
-import org.apache.geode.SystemFailure;
-import org.apache.geode.admin.*;
-import org.apache.geode.admin.internal.AdminDistributedSystemImpl;
-import org.apache.geode.admin.internal.CacheServerConfigImpl;
-import org.apache.geode.admin.internal.DistributionLocatorImpl;
-import org.apache.geode.cache.persistence.PersistentID;
-import org.apache.geode.distributed.DistributedMember;
-import org.apache.geode.distributed.internal.DistributionConfig;
-import org.apache.geode.distributed.internal.InternalDistributedSystem;
-import 
org.apache.geode.distributed.internal.membership.InternalDistributedMember;
-import org.apache.geode.internal.Assert;
-import org.apache.geode.internal.admin.Alert;
-import org.apache.geode.internal.admin.*;
-import org.apache.geode.internal.admin.remote.UpdateAlertDefinitionMessage;
-import org.apache.geode.internal.i18n.LocalizedStrings;
-import org.apache.geode.internal.logging.InternalLogWriter;
-import org.apache.geode.internal.logging.LogService;
-import org.apache.geode.internal.logging.log4j.LocalizedMessage;
-import org.apache.logging.log4j.Logger;
-
-import javax.management.*;
-import javax.management.modelmbean.ModelMBean;
-import javax.management.openmbean.*;
-import java.io.*;
-import java.net.InetAddress;
-import java.net.UnknownHostException;
-import java.util.*;
-import java.util.concurrent.atomic.AtomicInteger;
-
-/**
- * Provides MBean support for managing a GemFire distributed system.
- * <p>
- * TODO: refactor to implement DistributedSystem and delegate to instance of
- * DistributedSystemImpl. Wrap all delegate calls w/ e.printStackTrace() since 
- * the HttpAdaptor devours them (what to do w/ template methods then?)
- *
- * @since GemFire     3.5
- */
-public class AdminDistributedSystemJmxImpl 
-              extends AdminDistributedSystemImpl
-              implements ManagedResource, DistributedSystemConfig, 
StatAlertsAggregator {
-
-  private static final Logger logger = LogService.getLogger();
-  
-  private Properties mailProps;
-
-  // The file name where the StatAlertDefinitions would be serialized
-  private String statAlertDefnSerFile = System.getProperty("user.dir");
-  
-  /** 
-   * Simple counter incrementing on each notification.  This this currently 
-   * resets at every restart of Agent
-   */
-  private final AtomicInteger notificationSequenceNumber = new AtomicInteger();
-
-  /**
-   * Variable to indicate if there are no Rmi clients connected.
-   */
-  private volatile boolean isRmiClientCountZero;
-
-  /**
-   * Variable to indicate if Statistics Alert definitions could be persisted 
-   * across runs/sessions.
-   */
-  private volatile boolean canPersistStatAlertDefs = true;
-
-  /** Cache Listener to listen to Cache & Region create/destroy events */
-  private CacheAndRegionListenerImpl cacheRegionListener;
-
-  // -------------------------------------------------------------------------
-  //   Constructor(s)
-  // -------------------------------------------------------------------------
-  
-  /**
-   * Constructs new DistributedSystemJmxImpl and registers an MBean to 
represent
-   * it.
-   * 
-   * @param config
-   *          configuration defining the JMX agent.
-   */
-  public AdminDistributedSystemJmxImpl(AgentConfigImpl config)
-      throws org.apache.geode.admin.AdminException {
-    super(config);
-    this.mbeanName = "GemFire:type=AdminDistributedSystem,id="
-        + MBeanUtil.makeCompliantMBeanNameProperty(getId());
-    this.objectName = MBeanUtil.createMBean(this);
-    isEmailNotificationEnabled = config.isEmailNotificationEnabled();
-    if (isEmailNotificationEnabled) {
-      initMailProps(config);
-    }
-    // Init file name for StatAlertDefns
-    initStateSaveFile(config);
-    Assert.assertTrue(this.objectName != null);
-
-    cacheRegionListener = new CacheAndRegionListenerImpl(this);
-  }
-
-  private void initMailProps(AgentConfigImpl config) {
-    mailProps = new Properties();
-    mailProps.put(MailManager.PROPERTY_MAIL_FROM, 
-                    config.getEmailNotificationFrom());
-    mailProps.put(MailManager.PROPERTY_MAIL_HOST, 
-                    config.getEmailNotificationHost());
-    mailProps.put(MailManager.PROPERTY_MAIL_TO_LIST, 
-                    config.getEmailNotificationToList());
-  }
-
-  private void initStateSaveFile(AgentConfigImpl agentConfig) {
-    // Init file name for StatAlertDefns
-    AgentConfigImpl impl = (AgentConfigImpl) agentConfig;
-    File propFile = impl.getPropertyFile();
-
-    if (propFile!=null) {
-     if (propFile.isDirectory()) {
-       statAlertDefnSerFile = propFile.getAbsolutePath();
-     } else if (propFile.getParentFile()!=null) {
-       statAlertDefnSerFile = propFile.getParentFile().getAbsolutePath();
-     }
-    }
-
-    statAlertDefnSerFile = statAlertDefnSerFile + File.separator + 
agentConfig.getStateSaveFile();
-  }
-  
-  // -------------------------------------------------------------------------
-  //   MBean operations
-  // -------------------------------------------------------------------------
-  
-  /**
-   * Registers the MBeans for monitoring the health of GemFire 
-   *
-   * @see 
org.apache.geode.admin.internal.AdminDistributedSystemImpl#getGemFireHealth
-   */
-  public ObjectName monitorGemFireHealth() throws MalformedObjectNameException 
{
-    GemFireHealthJmxImpl health = (GemFireHealthJmxImpl) getGemFireHealth();
-    health.ensureMBeansAreRegistered();
-    return health.getObjectName();
-  }
-
-  /**
-   * Creates a new DistributionLocator for this system and registers an MBean
-   * for managing it.
-   * <p>
-   * If the Locator already exists, then this will simply register an MBean
-   * for it.
-   *
-   * @param host              the host name or IP address of the locator
-   * @param port              the port the locator service listens on
-   * @param workingDirectory  directory path for the locator and its log
-   * @param productDirectory  directory path to the GemFire product to use 
-   */
-  public ObjectName createDistributionLocator(String host,
-                                              int port,
-                                              String workingDirectory,
-                                              String productDirectory) 
-                                       throws MalformedObjectNameException {
-    return createDistributionLocator(
-        host, port, workingDirectory, productDirectory, getRemoteCommand());
-  }
-  
-  /**
-   * Creates a new DistributionLocator for this system and registers an MBean
-   * for managing it.
-   * <p>
-   * If the Locator already exists, then this will simply register an MBean
-   * for it.
-   *
-   * @param host              the host name or IP address of the locator
-   * @param port              the port the locator service listens on
-   * @param workingDirectory  directory path for the locator and its log
-   * @param productDirectory  directory path to the GemFire product to use 
-   * @param remoteCommand     formatted remote command to control remotely
-   */
-  public ObjectName createDistributionLocator(String host,
-                                              int port,
-                                              String workingDirectory,
-                                              String productDirectory,
-                                              String remoteCommand) 
-                                       throws MalformedObjectNameException {
-    try {
-      DistributionLocatorJmxImpl locator =
-        (DistributionLocatorJmxImpl) addDistributionLocator();
-      
-      DistributionLocatorConfig config = locator.getConfig();
-      config.setHost(host);
-      config.setPort(port);
-      config.setWorkingDirectory(workingDirectory);
-      config.setProductDirectory(productDirectory);
-      config.setRemoteCommand(remoteCommand);
-
-      return new ObjectName(locator.getMBeanName());
-    } catch (RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-  
-  // -------------------------------------------------------------------------
-  //   Template methods overriden from superclass...
-  // -------------------------------------------------------------------------
-  
-  /** Override createSystemMember by instantiating SystemMemberJmxImpl */
-  @Override
-  protected SystemMember createSystemMember(ApplicationVM app)
-  throws org.apache.geode.admin.AdminException {
-    return new SystemMemberJmxImpl(this, app);
-  }
-
-  /**
-   * Constructs & returns a SystemMember instance using the corresponding
-   * InternalDistributedMember object.
-   * 
-   * @param member
-   *          InternalDistributedMember instance for which a SystemMember
-   *          instance is to be constructed.
-   * @return constructed SystemMember instance
-   * @throws org.apache.geode.admin.AdminException
-   *           if construction of SystemMember instance fails
-   *
-   * @since GemFire 6.5
-   */
-  protected SystemMember createSystemMember(InternalDistributedMember member)
-      throws org.apache.geode.admin.AdminException {
-    return new SystemMemberJmxImpl(this, member);
-  }
-  
-
-  @Override
-  protected CacheServer createCacheServer(ApplicationVM member) 
-    throws AdminException {
-
-    return new CacheServerJmxImpl(this, member);
-  }
-
-  @Override
-  protected CacheServer createCacheServer(CacheServerConfigImpl config) 
-    throws AdminException {
-
-    return new CacheServerJmxImpl(this, config);
-  }
-
-  /** Override createGemFireHealth by instantiating GemFireHealthJmxImpl */
-  @Override
-  protected GemFireHealth createGemFireHealth(GfManagerAgent system) 
-    throws org.apache.geode.admin.AdminException {
-    if (system == null) {
-      throw new 
IllegalStateException(LocalizedStrings.AdminDistributedSystemJmxImpl_GFMANAGERAGENT_MUST_NOT_BE_NULL.toLocalizedString());
-    }
-    return new GemFireHealthJmxImpl(system, this);
-  }
-  
-  /** Template-method for creating a DistributionLocatorImpl instance. */
-  @Override
-  protected DistributionLocatorImpl 
-    createDistributionLocatorImpl(DistributionLocatorConfig config) {
-    return new DistributionLocatorJmxImpl(config, this);
-  }
-
-  // -------------------------------------------------------------------------
-  //   Internal Admin listeners and JMX Notifications
-  // -------------------------------------------------------------------------
-  
-  /** Notification type for indicating system member joined */
-  public static final String NOTIF_MEMBER_JOINED =
-      DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.member.joined";
-  /** Notification type for indicating system member left */
-  public static final String NOTIF_MEMBER_LEFT =
-      DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.member.left";
-  /** Notification type for indicating system member crashed */
-  public static final String NOTIF_MEMBER_CRASHED =
-      DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.member.crashed";
-  /** Notification type for sending GemFire alerts as JMX notifications */
-  public static final String NOTIF_ALERT =
-      DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.alert";
-  /** Notification type for sending GemFire StatAlerts as JMX notifications */
-  public static final String NOTIF_STAT_ALERT =
-      DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.statalert";
-  /** Notification type for indicating abnormal disconnection from the 
distributed system */
-  public static final String NOTIF_ADMIN_SYSTEM_DISCONNECT =
-      DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.disconnect";
-  
-  
-  private static final String EML_SUBJ_PRFX_GFE_ALERT = "[GemFire Alert] ";
-  private static final String EML_SUBJ_PRFX_GFE_NOTFY = "[GemFire 
Notification] ";
-  private static final String EML_SUBJ_ITEM_GFE_DS = "Distributed System: ";
-
-  // --------- org.apache.geode.internal.admin.JoinLeaveListener ---------
-  /** 
-   * Listener callback for when a member has joined this DistributedSystem.
-   * <p>
-   * React by creating an MBean for managing the SystemMember and then fire
-   * a Notification with the internal Id of the member VM.
-   *
-   * @param source  the distributed system that fired nodeJoined
-   * @param joined  the VM that joined
-   * @see org.apache.geode.internal.admin.JoinLeaveListener#nodeJoined
-   */
-  @Override
-  public void nodeJoined(GfManagerAgent source, GemFireVM joined) {
-    try {
-      super.nodeJoined(source, joined);
-      
-      /* super.nodeJoined results in creation of a new SystemMember which 
-       * registers itself as an MBean, so now we try to find it...
-       */
-      SystemMember member = findSystemMember(joined);
-      
-      if(null == member) {
-        if (logger.isDebugEnabled()) {
-          logger.debug("AdminDistributedSystemJmxImpl.nodeJoined(), Could not 
find SystemMember for VM {}", joined);
-        }
-        return;
-      }
-      
-      try {
-        if (logger.isDebugEnabled()) {
-          logger.debug("Processing node joined for: {}", member);
-          logger.debug("RemoteGemFireVM.nodeJoined(), setting alerts manager 
*************");
-        }
-        setAlertsManager(joined);
-        
-        this.modelMBean.sendNotification(new Notification(
-            NOTIF_MEMBER_JOINED,
-            ((ManagedResource)member).getObjectName(), // Pass the ObjName of 
the Source Member
-            notificationSequenceNumber.addAndGet(1),
-            joined.getId().toString()));
-
-//      String mess = "Gemfire AlertNotification: System Member Joined, System 
member Id: " + joined.getId().toString();
-//      sendEmail("Gemfire AlertNotification: Member Joined, ID: " + 
joined.getId().toString(), mess);
-        if (isEmailNotificationEnabled) {
-          String mess = 
LocalizedStrings.AdminDistributedSystemJmxImpl_MEMBER_JOINED_THE_DISTRIBUTED_SYSTEM_MEMBER_ID_0.toLocalizedString(new
 Object[] {joined.getId().toString()} );
-               sendEmail(
-                   EML_SUBJ_PRFX_GFE_NOTFY + EML_SUBJ_ITEM_GFE_DS + getName() 
+ " <" 
-                   + 
LocalizedStrings.AdminDistributedSystemJmxImpl_MEMBER_JOINED.toLocalizedString()
 +">", 
-                   mess);
-        }
-      } catch (javax.management.MBeanException e) {
-        logger.warn(e.getMessage(), e);
-      }
-    } catch (RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-  
-  /** 
-   * Listener callback for when a member has left this DistributedSystem.
-   * <p>
-   * React by removing the member's MBean.
-   * Also fire a Notification with the internal Id of the member VM.
-   *
-   * @param source  the distributed system that fired nodeLeft
-   * @param left    the VM that left
-   * @see org.apache.geode.internal.admin.JoinLeaveListener#nodeLeft
-   */
-  @Override
-  public void nodeLeft(GfManagerAgent source, GemFireVM left) {
-    try {
-      SystemMember member = findSystemMember(left, false);
-      super.nodeLeft(source, left);
-      if (logger.isDebugEnabled()) {
-        logger.debug("Processing node left for: {}", member);
-      }
-      try {
-        this.modelMBean.sendNotification(new Notification(
-            NOTIF_MEMBER_LEFT,
-            ((ManagedResource)member).getObjectName(), // Pass the ObjName of 
the Source Member
-            notificationSequenceNumber.addAndGet(1),
-            left.getId().toString()));
-
-//        String mess = "Gemfire AlertNotification: System Member Left the 
system, System member Id: " + left.getId().toString();
-//        sendEmail("Gemfire AlertNotification: Member Left, ID: " + 
left.getId().toString(), mess);
-        if (isEmailNotificationEnabled) {
-          String mess = 
LocalizedStrings.AdminDistributedSystemJmxImpl_MEMBER_LEFT_THE_DISTRIBUTED_SYSTEM_MEMBER_ID_0.toLocalizedString(new
 Object[] {left.getId().toString()} );
-               sendEmail( 
-                   EML_SUBJ_PRFX_GFE_NOTFY + EML_SUBJ_ITEM_GFE_DS + getName() 
+ " <" 
-                   + 
LocalizedStrings.AdminDistributedSystemJmxImpl_MEMBER_LEFT.toLocalizedString() 
+">", 
-                   mess);
-        }
-      } catch (javax.management.MBeanException e) { 
-        logger.warn(e.getMessage(), e);
-      }
-      
-      SystemMemberType memberType = member.getType();  
-      if (/* member != null && */ memberType.isApplication() || 
memberType.isCacheVm()) {
-        // automatically unregister the MBean...
-        MBeanUtil.unregisterMBean((ManagedResource) member);
-      }
-    } catch (RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-  
-  /** 
-   * Listener callback for when a member of this DistributedSystem has crashed.
-   * <p>
-   * Also fires a Notification with the internal Id of the member VM.
-   *
-   * @param source  the distributed system that fired nodeCrashed
-   * @param crashed the VM that crashed
-   * @see org.apache.geode.internal.admin.JoinLeaveListener#nodeCrashed
-   */
-  @Override
-  public void nodeCrashed(GfManagerAgent source, GemFireVM crashed) {
-    try {
-      // SystemMember application has left...
-      SystemMember member = findSystemMember(crashed, false);
-      super.nodeCrashed(source, crashed);
-      if (logger.isDebugEnabled()) {
-        logger.debug("Processing node crash for: {}", member);
-      }
-      
-      try {
-        this.modelMBean.sendNotification(new Notification(
-            NOTIF_MEMBER_CRASHED,
-            ((ManagedResource)member).getObjectName(), // Pass the ObjName of 
the Source Member
-            notificationSequenceNumber.addAndGet(1),
-            crashed.getId().toString()));
-        
-//        String mess = "Gemfire AlertNotification: System Member Crashed, 
System member Id: " + crashed.getId().toString();
-//        sendEmail("Gemfire AlertNotification: Member Crashed, ID: " + 
crashed.getId().toString(), mess);
-        if (isEmailNotificationEnabled) {
-          String mess = 
LocalizedStrings.AdminDistributedSystemJmxImpl_MEMBER_CRASHED_IN_THE_DISTRIBUTED_SYSTEM_MEMBER_ID_0.toLocalizedString(new
 Object[] {crashed.getId().toString()} );
-               sendEmail(
-                   EML_SUBJ_PRFX_GFE_ALERT + EML_SUBJ_ITEM_GFE_DS + getName() 
+ " <" 
-                   + 
LocalizedStrings.AdminDistributedSystemJmxImpl_MEMBER_CRASHED.toLocalizedString()
 +">", 
-                   mess);
-        }
-      } catch (javax.management.MBeanException e) {
-        logger.warn(e.getMessage(), e);
-      }
-
-      SystemMemberType memberType = member.getType();
-      if (/* member != null && */ memberType.isApplication() || 
memberType.isCacheVm()) {
-        // automatically unregister the MBean...
-        MBeanUtil.unregisterMBean((ManagedResource) member);
-      }
-    } catch (RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-
-  // ----------- org.apache.geode.internal.admin.AlertListener -----------
-  /** 
-   * Listener callback for when a SystemMember of this DistributedSystem has 
-   * crashed.
-   * <p>
-   * Fires a Notification with the information from the alert.
-   *
-   * @param alert the gemfire alert to broadcast as a notification
-   * @see org.apache.geode.internal.admin.AlertListener#alert
-   */
-  @Override
-  public void alert(Alert alert) {
-    try {
-      super.alert(alert);
-      try {
-        String strAlert = alert.toString();
-        this.modelMBean.sendNotification(new Notification(
-            NOTIF_ALERT,
-            this.mbeanName,
-            notificationSequenceNumber.addAndGet(1),
-            strAlert));
-        
-//        String mess = "Gemfire AlertNotification: System Alert :" + 
alert.toString();
-//        sendEmail("Gemfire AlertNotification: System Alert", mess);
-        if (isEmailNotificationEnabled) {
-          String mess = 
LocalizedStrings.AdminDistributedSystemJmxImpl_SYSTEM_ALERT_FROM_DISTRIBUTED_SYSTEM_0.toLocalizedString(strAlert);
-               sendEmail( EML_SUBJ_PRFX_GFE_ALERT + EML_SUBJ_ITEM_GFE_DS + 
getName() + " <System Alert>", mess);
-        }
-      } catch (javax.management.MBeanException e) {
-        logger.warn(e.getMessage(), e);
-      }
-    } catch (RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-  
-  @Override
-  public void onDisconnect(InternalDistributedSystem sys) {
-    if (logger.isDebugEnabled()) {
-      this.logger.debug("Calling AdminDistributedSystemJmxImpl#onDisconnect");
-    }
-       try {
-               super.onDisconnect(sys);
-               
-               try {
-                       this.modelMBean.sendNotification(new Notification(
-                               NOTIF_ADMIN_SYSTEM_DISCONNECT,
-                               this.mbeanName,
-                               notificationSequenceNumber.addAndGet(1),
-                               null));
-               } catch (MBeanException e) {
-                 logger.warn(e.getMessage(), e);       
-               }
-       } catch (RuntimeException e) {
-         logger.warn(e.getMessage(), e);
-         throw e;
-       } catch (VirtualMachineError err) {
-         SystemFailure.initiateFailure(err);
-         // If this ever returns, rethrow the error. We're poisoned
-         // now, so don't let this thread continue.
-         throw err;
-       } catch (Error e) {
-         // Whenever you catch Error or Throwable, you must also
-         // catch VirtualMachineError (see above). However, there is
-         // _still_ a possibility that you are dealing with a cascading
-         // error condition, so you also need to check to see if the JVM
-         // is still usable:
-         SystemFailure.checkFailure();
-         logger.error(e.getMessage(), e);
-         throw e;
-       }
-       if (logger.isDebugEnabled()) {
-         this.logger.debug("Completed 
AdminDistributedSystemJmxImpl#onDisconnect");
-       }
-  }
-  
-  // -------------------------------------------------------------------------
-  //   ManagedResource implementation
-  // -------------------------------------------------------------------------
-  
-  /** The name of the MBean that will manage this resource */
-  private String mbeanName;
-
-  /** The remotable ObjectName that the  MBean is registered under */
-  final private ObjectName objectName;
-  
-  /** The ModelMBean that is configured to manage this resource */
-  private ModelMBean modelMBean;
-  
-       public String getMBeanName() {
-               return this.mbeanName;
-       }
-  
-       public ModelMBean getModelMBean() {
-               return this.modelMBean;
-       }
-       public void setModelMBean(ModelMBean modelMBean) {
-               this.modelMBean = modelMBean;
-       }
-
-  public ObjectName getObjectName() {
-    return this.objectName;
-  }
-
-  public ManagedResourceType getManagedResourceType() {
-    return ManagedResourceType.DISTRIBUTED_SYSTEM;
-  }
-  
-  // -------------------------------------------------------------------------
-  //   Error traps added to overridden methods...
-  // -------------------------------------------------------------------------
-  
-  @Override
-  public boolean isRunning() {
-    try {
-      return super.isRunning();
-    } catch (java.lang.RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (java.lang.Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-
-  @Override
-  public void start() throws AdminException {
-    try {
-      super.start();
-    } catch (java.lang.RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (java.lang.Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-  
-  @Override
-  public void stop() throws AdminException {
-    try {
-      super.stop();
-    } catch (java.lang.RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (java.lang.Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-
-  @Override
-  public boolean waitToBeConnected(long timeout)
-    throws InterruptedException {
-
-    if (Thread.interrupted()) throw new InterruptedException();
-    try {
-      return super.waitToBeConnected(timeout);
-    } catch (java.lang.RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (java.lang.Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-
-  @Override
-  public String displayMergedLogs() {
-    try {
-      return super.displayMergedLogs();
-    } catch (java.lang.RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (java.lang.Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-
-  public ObjectName manageDistributionLocator()
-    throws MalformedObjectNameException {
-
-    try {
-      return new ObjectName(((ManagedResource) 
addDistributionLocator()).getMBeanName());
-    }
-//     catch (AdminException e) { logger.warn(e.getMessage(), e); throw e; }
-    catch (RuntimeException e) {
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-
-  public ObjectName[] manageDistributionLocators() 
-  throws MalformedObjectNameException {
-    try {
-      DistributionLocator[] locs = getDistributionLocators();
-      ObjectName[] onames = new javax.management.ObjectName[locs.length];
-      for (int i = 0; i < locs.length; i++) {
-        DistributionLocatorJmxImpl loc = (DistributionLocatorJmxImpl) locs[i];
-        onames[i] = new ObjectName(loc.getMBeanName());
-      }
-      return onames;
-    }
-    //catch (AdminException e) { logger.warn(e.getMessage(), e); throw e; }
-    catch (RuntimeException e) { 
-      logger.warn(e.getMessage(), e); 
-      throw e; 
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e); 
-      throw e; 
-    }
-  }
-    
-  /**
-   * @deprecated as of 5.7 use {@link #manageCacheVm} instead.
-   */
-  @Deprecated
-  public ObjectName manageCacheServer()
-  throws AdminException, MalformedObjectNameException {
-    return manageCacheVm();
-  }
-  public ObjectName manageCacheVm()
-  throws AdminException, MalformedObjectNameException {
-    try {
-      return new ObjectName(((ManagedResource) addCacheVm()).getMBeanName());
-    } catch (AdminException e) { 
-      logger.warn(e.getMessage(), e); 
-      throw e; 
-    } catch (RuntimeException e) { 
-      logger.warn(e.getMessage(), e); 
-      throw e; 
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.warn(e.getMessage(), e);
-      throw e; 
-    }
-  }
-
-  /**
-   * @deprecated as of 5.7 use {@link #manageCacheVms} instead.
-   */
-  @Deprecated
-  public ObjectName[] manageCacheServers()
-  throws AdminException, MalformedObjectNameException {
-    return manageCacheVms();
-  }
-
-  public ObjectName[] manageCacheVms()
-  throws AdminException, MalformedObjectNameException {
-    try {
-      CacheVm[] mgrs = getCacheVms();
-      ObjectName[] onames = new javax.management.ObjectName[mgrs.length];
-      for (int i = 0; i < mgrs.length; i++) {
-        CacheServerJmxImpl mgr = (CacheServerJmxImpl) mgrs[i];
-        onames[i] = new ObjectName(mgr.getMBeanName());
-      }
-      return onames;
-    } catch (AdminException e) { 
-      logger.warn(e.getMessage(), e); 
-      throw e; 
-    } catch (RuntimeException e) { 
-      logger.warn(e.getMessage(), e); 
-      throw e; 
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e; 
-    }
-  }
-
-  public ObjectName[] manageSystemMemberApplications()
-  throws AdminException, MalformedObjectNameException {
-    try {
-      SystemMember[] apps = getSystemMemberApplications();
-      ObjectName[] onames = new javax.management.ObjectName[apps.length];
-      for (int i = 0; i < apps.length; i++) {
-        SystemMemberJmxImpl app = (SystemMemberJmxImpl) apps[i];
-        onames[i] = new ObjectName(app.getMBeanName());
-      }
-      return onames;
-    } catch (AdminException e) { 
-      logger.warn(e.getMessage(), e); 
-      throw e; 
-    } catch (RuntimeException e) { 
-      logger.warn(e.getMessage(), e); 
-      throw e; 
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e; 
-    }
-  }
-  
-  /**
-   * Return the ObjectName for the SystemMemberMBean representing the
-   * specified distributed member or null if the member is not found.
-   *
-   * @param distributedMember the distributed member to manage
-   * @return the ObjectName for the SystemMemberMBean
-   */
-  public ObjectName manageSystemMember(DistributedMember distributedMember)
-  throws AdminException, MalformedObjectNameException {
-    try {
-      SystemMember member = lookupSystemMember(distributedMember);
-      if (member == null) return null;
-      SystemMemberJmxImpl jmx = (SystemMemberJmxImpl) member;
-      ObjectName oname = new ObjectName(jmx.getMBeanName());
-      return oname;
-    } catch (AdminException e) { 
-      logger.warn(e.getMessage(), e); 
-      throw e; 
-    } catch (RuntimeException e) { 
-      logger.warn(e.getMessage(), e); 
-      throw e; 
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e; 
-    }
-  }
-  
-  @Override
-  public void connect(InternalLogWriter logWriter) {
-    try {
-      // LOG: passes the AdminDistributedSystemImpl LogWriterLogger into 
GfManagerAgentConfig
-      super.connect(logWriter);
-      
-      // Load existing StatAlert Definitions
-      readAlertDefinitionsAsSerializedObjects();
-
-      /* Add Cache Listener to listen to Cache & Region create/destroy events 
*/
-      if (logger.isDebugEnabled()) {
-        logger.debug("Adding CacheAndRegionListener .... ");
-      }
-      addCacheListener(cacheRegionListener);
-    } catch (RuntimeException e) { 
-      logger.warn(e.getMessage(), e);
-      throw e; 
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e; 
-    }
-  }
-  
-  @Override
-  public void disconnect() {
-    try {
-      super.disconnect();
-      
-      // Save existing StatAlert Definitions
-      saveAlertDefinitionsAsSerializedObjects();
-
-      /* Remove Cache Listener to listen to Cache & Region create/destroy 
events */
-      if (logger.isDebugEnabled()) {
-        logger.debug("Removing CacheAndRegionListener .... ");
-      }
-      removeCacheListener(cacheRegionListener);      
-    } catch (RuntimeException e) { 
-      logger.warn(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, re-throw the error.  We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) { 
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above).  However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-
-  public void cleanupResource() {
-    disconnect();
-  }
-  
-  /**
-   * @return the isRmiClientCountZero
-   * @since GemFire 6.0
-   */
-  public boolean isRmiClientCountZero() {
-    return isRmiClientCountZero;
-  }
-
-  /**
-   * @param isRmiClientCountZero the isJmxClientCountZero to set
-   * @since GemFire 6.0
-   */
-  void setRmiClientCountZero(boolean isRmiClientCountZero) {
-    this.isRmiClientCountZero = isRmiClientCountZero;
-    
-    if (isRmiClientCountZero) {
-      
logger.info(LocalizedStrings.AdminDistributedSystemJmxImpl_JMX_CLIENT_COUNT_HAS_DROPPED_TO_ZERO);
-    }
-  }
-
-
-  ///////////////////////  Configuration  ///////////////////////
-
-  public String getEntityConfigXMLFile() {
-    return this.getConfig().getEntityConfigXMLFile();
-  }
-
-  public void setEntityConfigXMLFile(String xmlFile) {
-    this.getConfig().setEntityConfigXMLFile(xmlFile);
-  }
-
-  public String getSystemId() {
-    return this.getConfig().getSystemId();
-  }
-
-  public void setSystemId(String systemId) {
-    this.getConfig().setSystemId(systemId);
-  }
-
-  @Override
-  public String getSystemName() {
-    return this.getConfig().getSystemName();
-  }
-
-  public void setSystemName(final String name) {
-    this.getConfig().setSystemName(name);
-  }
-    
-  @Override
-  public boolean getDisableTcp() {
-    return this.getConfig().getDisableTcp();
-  }
-
-  public void setEnableNetworkPartitionDetection(boolean newValue) {
-    getConfig().setEnableNetworkPartitionDetection(newValue);
-  }
-  public boolean getEnableNetworkPartitionDetection() {
-    return getConfig().getEnableNetworkPartitionDetection();
-  }
-  public int getMemberTimeout() {
-   return getConfig().getMemberTimeout();
-  }
-  public void setMemberTimeout(int value) {
-    getConfig().setMemberTimeout(value);
-  }
-  
-  @Override
-  public String getMcastAddress() {
-    return this.getConfig().getMcastAddress();
-  }
-
-  public void setMcastAddress(String mcastAddress) {
-    this.getConfig().setMcastAddress(mcastAddress);
-  }
-
-  @Override
-  public int getMcastPort() {
-    return this.getConfig().getMcastPort();
-  }
-  
-  public void setMcastPort(int mcastPort) {
-    this.getConfig().setMcastPort(mcastPort);
-  }
-
-  public int getAckWaitThreshold() {
-    return getConfig().getAckWaitThreshold();
-  }
-  
-  public void setAckWaitThreshold(int seconds) {
-    getConfig().setAckWaitThreshold(seconds);
-  }
-
-  public int getAckSevereAlertThreshold() {
-    return getConfig().getAckSevereAlertThreshold();
-  }
-  
-  public void setAckSevereAlertThreshold(int seconds) {
-    getConfig().setAckSevereAlertThreshold(seconds);
-  }
-
-  @Override
-  public String getLocators() {
-    return this.getConfig().getLocators();
-  }
-
-  @Override
-  public void setLocators(String locators) {
-    this.getConfig().setLocators(locators);
-  }
-  
-  /* Note that the getter & setter for membership port range are referred from 
-   * the super class AdminDistributedSystemImpl */
-
-  public String getBindAddress() {
-    return this.getConfig().getBindAddress();
-  }
-
-  public void setBindAddress(String bindAddress) {
-    this.getConfig().setBindAddress(bindAddress);
-  }
-  
-  public String getServerBindAddress() {
-    return this.getConfig().getServerBindAddress();
-  }
-
-  public void setServerBindAddress(String bindAddress) {
-    this.getConfig().setServerBindAddress(bindAddress);
-  }
-
-  @Override
-  public String getRemoteCommand() {
-    return this.getConfig().getRemoteCommand();
-  }
-
-  @Override
-  public void setRemoteCommand(String command) {
-    this.getConfig().setRemoteCommand(command);
-  }
-
-  public boolean isSSLEnabled() {
-    return this.getConfig().isSSLEnabled();
-  }
-
-  public void setSSLEnabled(boolean enabled) {
-    this.getConfig().setSSLEnabled(enabled);
-  }
-
-  public String getSSLProtocols() {
-    return this.getConfig().getSSLProtocols();
-  }
-
-  public void setSSLProtocols(String protocols) {
-    this.getConfig().setSSLProtocols(protocols);
-  }
-
-  public String getSSLCiphers() {
-    return this.getConfig().getSSLCiphers();
-  }
-
-  public void setSSLCiphers(String ciphers) {
-    this.getConfig().setSSLCiphers(ciphers);
-  }
-
-  public boolean isSSLAuthenticationRequired() {
-    return this.getConfig().isSSLAuthenticationRequired();
-  }
-
-  public void setSSLAuthenticationRequired(boolean authRequired) {
-    this.getConfig().setSSLAuthenticationRequired(authRequired);
-  }
-  
-  public Properties getSSLProperties() {
-    return this.getConfig().getSSLProperties();
-  }
-
-  public void setSSLProperties(Properties sslProperties) {
-    this.getConfig().setSSLProperties(sslProperties);
-  }
-
-  public void addSSLProperty(String key, String value) {
-    this.getConfig().addSSLProperty(key, value);
-  }
-
-  public void removeSSLProperty(String key) {
-    this.getConfig().removeSSLProperty(key);
-  }
-  
-  public String getLogFile() {
-    return this.getConfig().getLogFile();
-  }
-
-  public void setLogFile(String logFile) {
-    this.getConfig().setLogFile(logFile);
-  }
-
-  public String getLogLevel() {
-    return this.getConfig().getLogLevel();
-  }
-
-  public void setLogLevel(String logLevel) {
-    this.getConfig().setLogLevel(logLevel);
-  }
-
-  public int getLogDiskSpaceLimit() {
-    return this.getConfig().getLogDiskSpaceLimit();
-  }
-
-  public void setLogDiskSpaceLimit(int limit) {
-    this.getConfig().setLogDiskSpaceLimit(limit);
-  }
-
-  public int getLogFileSizeLimit() {
-    return this.getConfig().getLogFileSizeLimit();
-  }
-
-  public void setLogFileSizeLimit(int limit) {
-    this.getConfig().setLogFileSizeLimit(limit);
-  }
-
-  public void setDisableTcp(boolean flag) {
-    this.getConfig().setDisableTcp(flag);
-  }
-
-  public int getRefreshInterval() {
-    return this.getConfig().getRefreshInterval();
-  }
-
-  /*
-   * The interval (in seconds) between auto-polling for updating
-   * AdminDistributedSystem constituents including SystemMember,
-   * SystemMemberCache and StatisticResource. This applies only to the default
-   * interval set when the resource is created. Changes to this interval will
-   * not get propagated to existing resources but will apply to all new
-   * resources
-   */
-  public void setRefreshInterval(int interval) {
-    this.getConfig().setRefreshInterval(interval);
-  }
-
-  public CacheServerConfig[] getCacheServerConfigs() {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  public CacheServerConfig createCacheServerConfig() {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  public void removeCacheServerConfig(CacheServerConfig config) {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  public CacheVmConfig[] getCacheVmConfigs() {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  public CacheVmConfig createCacheVmConfig() {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  public void removeCacheVmConfig(CacheVmConfig config) {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  public DistributionLocatorConfig[] getDistributionLocatorConfigs() {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-  
-  public DistributionLocatorConfig createDistributionLocatorConfig() {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  public void removeDistributionLocatorConfig(DistributionLocatorConfig 
config) 
-{
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  public void addListener(ConfigListener listener) {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  public void removeListener(ConfigListener listener) {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  public void validate() {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-
-  @Override
-  public Object clone() throws CloneNotSupportedException {
-    throw new 
UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString());
-  }
-  
-
-  private static final String[] PERSISTENT_ID_FIELDS = new String[] {"host", 
"directory", "uuid"};
-  private static final String[] PERSISTENT_ID_DESCRIPTIONS = new String[] 
{"The host that was persisting the missing files", "The directory where the 
files were persisted", "The unique id for the persistent files"};
-  private final CompositeType PERSISTENT_ID_TYPE;
-  private final TabularType PERSISTENT_ID_TABLE_TYPE;
-  
-  { 
-    try {
-      PERSISTENT_ID_TYPE = new 
CompositeType(PersistentID.class.getCanonicalName(), "A single member's a set 
of persistent files for a region", PERSISTENT_ID_FIELDS, 
PERSISTENT_ID_DESCRIPTIONS, new OpenType[] {SimpleType.STRING, 
SimpleType.STRING, SimpleType.STRING});
-      PERSISTENT_ID_TABLE_TYPE = new TabularType("TABLE_" + 
PERSISTENT_ID_TYPE.getTypeName(), "A table of persistent member ids", 
PERSISTENT_ID_TYPE, PERSISTENT_ID_FIELDS);
-    } catch (OpenDataException e) {
-      throw new ExceptionInInitializerError(e);
-    }
-  }
-  
-  public TabularData getMissingPersistentMembersJMX() throws AdminException {
-    
-    try {
-      Set<PersistentID> members = super.getMissingPersistentMembers();
-      TabularData results = new TabularDataSupport(PERSISTENT_ID_TABLE_TYPE);
-      int index = 0;
-      for(PersistentID id : members) {
-        CompositeData idData = new CompositeDataSupport(PERSISTENT_ID_TYPE, 
PERSISTENT_ID_FIELDS, new Object[] {id.getHost().toString(), id.getDirectory(), 
id.getUUID().toString()});
-        results.put(idData);
-        index++;
-      }
-      return results;
-    } catch( OpenDataException e) {
-      logger.warn("Exception occurred while getting missing persistent 
members.", e);
-      throw new AdminException(e);
-    }
-  }
-
-  public void revokePersistentMember(String host,
-      String directory) throws AdminException, UnknownHostException {
-    super.revokePersistentMember(InetAddress.getByName(host), directory);
-  }
-  
-  public void revokePersistentMember(String uuid) throws AdminException, 
UnknownHostException {
-    super.revokePersistentMember(UUID.fromString(uuid));
-  }
-
-  /* ********************************************************************* */
-  /* ************** Implementing StatAlertsAggregator interface ********** */
-  /* ********************************************************************* */
-  
-  /* Map to store admin stat alert definitions */
-  private final Map ALERT_DEFINITIONS = new Hashtable();
-  
-  /* Refresh interval for all stat alerts managers in seconds */
-  private int refreshIntervalForStatAlerts = 20;
-
-  /* 
-   * This map contains list of stat alerts as a value for alert def ID as a 
key  
-   */
-  private final HashMap alertsStore = new HashMap();
-  
-  //TODO: yet to set the timer task
-//  private SystemTimer systemwideAlertNotificationScheduler = new 
SystemTimer();
-  
-  private MailManager mailManager = null;
-  private final boolean isEmailNotificationEnabled;
-  
-  /**
-   * Convenience method to retrieve admin stat alert definition.
-   * 
-   * @param alertDefinitionId id of a stat alert definition 
-   * @return StatAlertDefinition reference to an instance of 
StatAlertDefinition
-   * @since GemFire 5.7
-   */
-  private StatAlertDefinition getAlertDefinition(int alertDefinitionId) {
-    synchronized(ALERT_DEFINITIONS) {
-      return 
(StatAlertDefinition)ALERT_DEFINITIONS.get(Integer.valueOf(alertDefinitionId));
-    }
-  }
-  
-/*  private void setAlertDefinition(StatAlertDefinition alertDefinition) {
-    ALERT_DEFINITIONS.put(Integer.valueOf(alertDefinition.getId()), 
alertDefinition);
-  }*/
-
-  /** 
-   * This method can be used to get an alert definition. 
-   * 
-   * @param alertDefinition StatAlertDefinition to retrieve
-   * @return StatAlertDefinition 
-   * @since GemFire 5.7
-   */
-  public StatAlertDefinition getAlertDefinition(StatAlertDefinition 
alertDefinition) {
-    return getAlertDefinition(alertDefinition.getId());
-  }
-  
-  /**
-   * This method is used to write existing StatAlertDefinitions 
-   * to a file
-   */
-  protected void readAlertDefinitionsAsSerializedObjects() {
-    StatAlertDefinition[] defns = new StatAlertDefinition[0];
-
-    File serFile = null;
-    FileInputStream foStr = null;
-    DataInputStream ooStr = null;
-
-    try {
-      serFile = new File(statAlertDefnSerFile);
-      
-      if (!canWriteToFile(serFile)) {/* can not write a file */
-        canPersistStatAlertDefs = false;
-      }
-      if (!serFile.exists()) {/* file does not exist */
-        return;
-      }
-      
-      if (logger.isDebugEnabled()) {
-        
logger.debug("AdminDistributedSystemJmxImpl.readAlertDefinitionsAsSerializedObjects:
 File: {}", serFile.getPath());
-      }
-
-      foStr = new FileInputStream(serFile);
-      ooStr = new DataInputStream(foStr);
-      defns = (StatAlertDefinition[])DataSerializer.readObjectArray(ooStr);
-    } catch (ClassNotFoundException cnfEx) {
-      logger.error(LocalizedMessage.create(
-          
LocalizedStrings.AdminDistributedSystem_ENCOUNTERED_A_0_WHILE_LOADING_STATALERTDEFINITIONS_1,
-          new Object[] {cnfEx.getClass().getName(), statAlertDefnSerFile}), 
cnfEx);
-      canPersistStatAlertDefs = false;
-    } catch (IOException ex) {
-      logger.error(LocalizedMessage.create(
-          
LocalizedStrings.AdminDistributedSystem_ENCOUNTERED_A_0_WHILE_LOADING_STATALERTDEFINITIONS_1_LOADING_ABORTED,
-          new Object[] {ex.getClass().getName(), statAlertDefnSerFile}), ex);
-      canPersistStatAlertDefs = false;
-    } finally {
-      if (foStr!=null) {
-        try {
-          foStr.close();
-        } catch (IOException ex) {
-          ;
-        }
-      }
-      if (ooStr!=null) { 
-        try {
-          ooStr.close();
-        } catch (IOException ex) {
-          ;
-        }
-      }
-    }
-    
-    for (int i=0; i<defns.length; i++) {
-      updateAlertDefinition(defns[i]);
-    }
-  }
-
-  /**
-   * This method is used to write existing StatAlertDefinitions 
-   * to a file
-   */
-  public void saveAlertDefinitionsAsSerializedObjects() {
-    File serFile = null;
-    FileOutputStream foStr = null;
-    DataOutputStream ooStr = null;
-    try {
-      serFile = new File(statAlertDefnSerFile);
-      
-  
-      if (logger.isDebugEnabled()) {
-        
logger.debug("AdminDistributedSystemJmxImpl.saveAlertDefinitionsAsSerializedObjects:
 File: {}", serFile.getPath());
-      }
-      
-      if (!canWriteToFile(serFile)) {
-        return;
-      }
-      
-      foStr = new FileOutputStream(serFile);
-      ooStr = new DataOutputStream(foStr);
-      
-      int numOfAlerts = 0;
-      StatAlertDefinition[] defs = null;
-
-      synchronized (ALERT_DEFINITIONS) {
-        numOfAlerts = ALERT_DEFINITIONS.size();
-        defs = new StatAlertDefinition[numOfAlerts];
-        
-        int i = 0;
-        for (Iterator iter=ALERT_DEFINITIONS.keySet().iterator(); 
iter.hasNext() ;) {
-          Integer key = (Integer) iter.next();
-          StatAlertDefinition readDefn = (StatAlertDefinition) 
ALERT_DEFINITIONS.get(key);
-          defs[i] = readDefn;
-          i++; 
-        }
-      }
-
-      DataSerializer.writeObjectArray(defs, ooStr);
-    } catch (IOException ex) {
-      logger.error(LocalizedMessage.create(
-          
LocalizedStrings.AdminDistributedSystem_ENCOUNTERED_A_0_WHILE_SAVING_STATALERTDEFINITIONS_1,
-          new Object[] {ex.getClass().getName(), statAlertDefnSerFile}), ex);
-    } finally {
-      if (foStr!=null) 
-        try {
-          foStr.close();
-        } catch (IOException ex) {
-          ;
-        }
-      if (ooStr!=null) 
-        try {
-          ooStr.close();
-        } catch (IOException ex) {
-          ;
-        }
-    }
-  }
-
-  /**
-   * Checks if the given file is writable.
-   * 
-   * @param file
-   *          file to check write permissions for
-   * @return true if file is writable, false otherwise
-   */
-  private boolean canWriteToFile(File file) {
-    boolean fileIsWritable = true;
-    // Fix for BUG40360 : When the user does not have write permissions for
-    // saving the stat-alert definitions, then appropriate warning message is 
-    // logged and the operation is aborted. In case the file doesn't exist, 
then 
-    // it attempts to create a file. If the attempt fails then it logs 
-    // appropriate warning and the operation is aborted. File.canWrite check 
for
-    // a directory sometimes fails on Windows platform. Hence file creation is 
-    // necessary.
-    if (file.exists()) {
-      if (!file.canWrite()) {
-        logger.warn(LocalizedMessage.create(
-            
LocalizedStrings.AdminDistributedSystemJmxImpl_READONLY_STAT_ALERT_DEF_FILE_0,
-            new Object[] { file }));
-        fileIsWritable = false;
-      }
-    } else {
-      try {
-        file.createNewFile();
-      } catch (IOException e) {
-        logger.warn(LocalizedMessage.create(
-            
LocalizedStrings.AdminDistributedSystemJmxImpl_FAILED_TO_CREATE_STAT_ALERT_DEF_FILE_0,
-            new Object[] { file }), e);
-        fileIsWritable = false;
-      } finally {
-        // Since we had created this file only for testing purpose, delete the
-        // same.
-        if ((file.exists() && !file.delete()) && logger.isDebugEnabled()) {
-          logger.debug("Could not delete file :'{}' which is created for 
checking permissions.", file.getAbsolutePath());
-        }
-      }
-    }
-    return fileIsWritable;
-  }
-
-  /** 
-   * This method can be used to update alert definition for the Stat mentioned.
-   * This method should update the collection maintained at the aggregator and 
-   * should notify members for the newly added alert definitions.
-   * A new alert definition will be created if matching one not found.
-   * 
-   * @param alertDefinition alertDefinition to be updated 
-   * @since GemFire 5.7
-   */  
-  public void updateAlertDefinition(StatAlertDefinition alertDefinition) {
-    if (logger.isDebugEnabled()) {
-      logger.debug("Entered 
AdminDistributedSystemJmxImpl.updateAlertDefinition(StatAlertDefinition) 
*****");
-    }
-    /*
-     * What to update in the alert definition? There should be another 
argument 
-     * or arguments in a map.
-     * 1. Need to update the list/map of alert definitions across members.   
-     */
-    synchronized (ALERT_DEFINITIONS) {
-      ALERT_DEFINITIONS.put(Integer.valueOf(alertDefinition.getId()), 
alertDefinition);
-      
-      if (logger.isDebugEnabled()) {
-        logger.debug("AdminDistributedSystemJmxImpl.updateAlertDefinition : 
alertDefinition :: id={} :: {}", alertDefinition.getId(), 
alertDefinition.getStringRepresentation());
-      }
-      
-      /* TODO: add code to retry on failure */
-      notifyMembersForAlertDefinitionChange(alertDefinition);
-    }
-    if (logger.isDebugEnabled()) {
-      logger.debug("Exiting 
AdminDistributedSystemJmxImpl.updateAlertDefinition(StatAlertDefinition) 
*****");
-    }
-  }
-
-  /** 
-   * This method can be used to remove alert definition for the Stat 
-   * mentioned. 
-   * This method should update the collection maintained at the aggregator and 
-   * should notify members for the newly added alert definitions. 
-   * 
-   * @param defId id of the alert definition to be removed
-   * @since GemFire 5.7
-   */  
-  public void removeAlertDefinition(Integer defId) {
-    if (logger.isDebugEnabled()) {
-      logger.debug("Entered 
AdminDistributedSystemJmxImpl.removeAlertDefinition id *****");
-    }
-    /*
-     * alert passed to be deleted from the list/map of alerts on JMX MBean 
-     * & all Member MBeans
-     */
-    synchronized (ALERT_DEFINITIONS) {
-      StatAlertDefinition alertDefinition = 
(StatAlertDefinition)ALERT_DEFINITIONS.get(defId);
-         if (alertDefinition != null) {
-               ALERT_DEFINITIONS.remove(defId);
-               synchronized (alertsStore) {
-                 alertsStore.remove(defId);
-               }
-               /* TODO: add code to retry on failure */
-               notifyMembersForAlertDefinitionRemoval(alertDefinition);
-         }      
-    }
-    if (logger.isDebugEnabled()) {
-      logger.debug("Exiting 
AdminDistributedSystemJmxImpl.removeAlertDefinition() *****");
-    }
-  }
-
-  /** 
-   * Convenience method to check whether an alert definition is created.
-   * 
-   * @param alertDefinition alert definition to check whether already created
-   * @return true if the alert definition is already created, false 
-   *         otherwise 
-   * @since GemFire 5.7
-   */
-  public boolean isAlertDefinitionCreated(StatAlertDefinition alertDefinition) 
{
-    /*
-     * Need to maintain a map of stat against the StatAlertDefinitions.
-     * check in that map whether the alert definition is there for the given 
-     * alert
-     * 
-     * TODO: optimize to use Map.containsKey - DONE
-     */
-    synchronized(ALERT_DEFINITIONS) {
-      return 
ALERT_DEFINITIONS.containsKey(Integer.valueOf(alertDefinition.getId()));
-    }
-  }
-
-  /**
-   * Returns the refresh interval for the Stats in seconds.
-   * 
-   * @return refresh interval for the Stats(in seconds)
-   * @since GemFire 5.7
-   */
-  public synchronized int getRefreshIntervalForStatAlerts() {
-    /*
-     * state to store the refresh interval set by the user/GFMon client 
-     */
-    return refreshIntervalForStatAlerts;
-  }
-
-  /**
-   * This method is used to set the refresh interval for the Stats in 
-   * seconds 
-   * 
-   * @param refreshIntervalForStatAlerts refresh interval for the Stats(in 
seconds)
-   * @since GemFire 5.7
-   */
-  public synchronized void setRefreshIntervalForStatAlerts(int 
refreshIntervalForStatAlerts) {
-    /*
-     * change the state refresh interval here. 
-     */
-    this.refreshIntervalForStatAlerts = refreshIntervalForStatAlerts;
-    
notifyMembersForRefreshIntervalChange(this.refreshIntervalForStatAlerts*1000l);
-  }
-
-  /**
-   * Returns whether Statistics Alert definitions could be persisted across 
-   * runs/sessions
-   * 
-   * @return value of canPersistStatAlertDefs.
-   * @since GemFire 6.5
-   */
-  public boolean canPersistStatAlertDefs() {
-    return canPersistStatAlertDefs;
-  }
-
-  /**
-   * An intermediate method to notify all members for change in refresh 
interval.
-   * 
-   * @param newInterval refresh interval to be set for members(in milliseconds)
-   */
-  private void notifyMembersForRefreshIntervalChange(long newInterval) {
-    GfManagerAgent  agent = getGfManagerAgent();
-    ApplicationVM[] VMs   = agent.listApplications();    
-    //TODO: is there any other way to get all VMs?
-    
-    for (int i = 0; i < VMs.length; i++) {
-      VMs[i].setRefreshInterval(newInterval);
-    }
-  }
-  
-  /**
-   * An intermediate method to notify all members for change in stat alert 
-   * definition.
-   * 
-   * @param alertDef stat alert definition that got changed
-   */  
-  private void notifyMembersForAlertDefinitionChange(StatAlertDefinition 
alertDef) {
-    if (logger.isDebugEnabled()) {
-      logger.debug("Entered 
AdminDistributedSystemJmxImpl.notifyMembersForAlertDefinitionChange(StatAlertDefinition)
 *****");
-    }
-    GfManagerAgent        agent     = getGfManagerAgent();
-    StatAlertDefinition[] alertDefs = new StatAlertDefinition[] {alertDef};
-    ApplicationVM[]       VMs       = agent.listApplications();
-    
-    for (int i = 0; i < VMs.length; i++) {
-      VMs[i].updateAlertDefinitions(alertDefs, 
-          UpdateAlertDefinitionMessage.UPDATE_ALERT_DEFINITION);
-    }
-
-    if (logger.isDebugEnabled()) {
-      logger.debug("Exiting 
AdminDistributedSystemJmxImpl.notifyMembersForAlertDefinitionChange(StatAlertDefinition)
 "
-                   + VMs.length+" members notified.*****");
-    }
-  }
-
-  /**
-   * An intermediate method to notify all members for removal of stat alert 
-   * definition.
-   * 
-   * @param alertDef stat alert definition to be removed
-   */
-  private void notifyMembersForAlertDefinitionRemoval(StatAlertDefinition 
alertDef) {
-    GfManagerAgent        agent     = getGfManagerAgent();
-    StatAlertDefinition[] alertDefs = new StatAlertDefinition[] {alertDef};
-    ApplicationVM[]       VMs       = agent.listApplications();
-    
-    for (int i = 0; i < VMs.length; i++) {
-      VMs[i].updateAlertDefinitions(alertDefs, 
-          UpdateAlertDefinitionMessage.REMOVE_ALERT_DEFINITION);
-    }
-  }
-
-  /**
-   * This method can be used to set the AlertsManager for the newly joined     
-   * member VM.
-   * 
-   * @param memberVM Member VM to set AlertsManager for
-   * @since GemFire 5.7
-   */
-  public synchronized void setAlertsManager(GemFireVM memberVM) {
-    /*
-     * 1. Who'll call this method? Who gets notified when a member joins? 
-     *    I think that's AdminDistributedSystemJmxImpl.nodeCreated()
-     * 2. Is the argument GemFireVM correct? Need to modify this interface to 
-     *    add method to set an interface. Need to see how it can be passed to 
-     *    the RemoteGemFireVM implementation. Also need to check whetherother 
-     *    implementors (like DistributedSystemHealthMonitor) of GemFireVM even 
-     *    need to have the AlertsManager
-     * 3. Would the alerts manager be set by aggregator or a JMXAgent i.e. 
AdminDistributedSystemJmxImpl
-     * 4. Setting the list of available alert definitions & refresh interval 
at 
-     *    this moment only would be better/easier.
-     * 5. Need to know Alerts Manager creation/construction. Need to decide 
how 
-     *    the object would be set & sent across to the Agent VM.
-     */
-    if (logger.isDebugEnabled()) {
-      logger.debug("Entered 
AdminDistributedSystemJmxImpl.setAlertsManager(GemFireVM) *****");
-    }
-    
-    // creating an array of stat alert definition objects
-    StatAlertDefinition[] alertDefs = new StatAlertDefinition[0];
-    
-    Collection alertDefsCollection = null;
-    synchronized(ALERT_DEFINITIONS) {
-      alertDefsCollection = ALERT_DEFINITIONS.values();
-    }
-    
-    alertDefs = (StatAlertDefinition[])alertDefsCollection.toArray(alertDefs);
-    
-    memberVM.setAlertsManager(alertDefs, 
getRefreshIntervalForStatAlerts()*1000l, true);
-    
-    if (logger.isDebugEnabled()) {
-      logger.debug("Exiting 
AdminDistributedSystemJmxImpl.setAlertsManager(GemFireVM) *****");
-    }
-  }
-
-  /** 
-   * This method can be used to retrieve all available stat alert definitions. 
-   * Returns empty array if there are no stat alert definitions defined.
-   * 
-   * @return An array of all available StatAlertDefinition objects 
-   * @since GemFire 5.7
-   */
-  public StatAlertDefinition[] getAllStatAlertDefinitions() {
-    if (logger.isDebugEnabled()) {
-      logger.debug("Entered 
AdminDistributedSystemJmxImpl.getAllStatAlertDefinitions() *****");
-    }
-    
-    Collection alertDefs = null;
-    synchronized(ALERT_DEFINITIONS) {
-      alertDefs = ALERT_DEFINITIONS.values();
-    }
-    
-    StatAlertDefinition[] alertDefsArr = null;
-    
-    if (alertDefs != null) {
-      alertDefsArr = new StatAlertDefinition[alertDefs.size()];
-      alertDefsArr = (StatAlertDefinition[])alertDefs.toArray(alertDefsArr);
-    } else {
-      alertDefsArr = new StatAlertDefinition[0];
-    }
-    
-    if (logger.isDebugEnabled()) {
-      logger.debug("Exiting 
AdminDistributedSystemJmxImpl.getAllStatAlertDefinitions() *****");
-    }
-    
-    return alertDefsArr;
-  }
-
-
-  /**
-   * This method can be used to process the notifications sent by the 
-   * member(s). Actual aggregation of stats can occur here. The array contains 
-   * alert objects with alert def. ID & value. AlertHelper class can be used 
to 
-   * retrieve the corresponding alert definition.
-   * 
-   * @param alerts array of Alert class(contains alert def. ID & value)
-   * @param remoteVM Remote Member VM that sent Stat Alerts for processing the
-   *                 notifications to the clients
-   */  
-  public void processNotifications(StatAlert[] alerts, GemFireVM remoteVM) {
-    if (logger.isDebugEnabled()) {
-      logger.debug("Entered 
AdminDistributedSystemJmxImpl.processNotifications(StatAlert[{}], GemFireVM) 
*************", alerts.length);
-    }
-    
-    /* 
-     * Notifications can not be processed if the remote VM is not available.
-     * NOTE: Should this method get the required GemFireVM information instead 
-     * of its reference so that even if the member leaves we still have the 
-     * information collected earlier to process the notification?
-     */
-    if (remoteVM == null) {
-      if (logger.isDebugEnabled()) {
-        logger.debug("Could not process stat alert notifications as given 
GemFireVM is null.");
-      }
-      return;
-    }
-    
-    /*
-     * 1. The implementation idea is yet not clear.
-     * 2. The StatAlert array would received directly or from a request 
object. 
-     */
-    ArrayList notificationObjects = new ArrayList();
-    
-    String memberId = remoteVM.getId().getId();
-
-    final boolean isSystemWide = false;
-    
-    StatAlert alert = null;
-    Integer   defId = null;
-//    Number[]  values = null;
-    for (int i = 0; i < alerts.length; i++) {
-      alert = alerts[i];
-      
-//      defId = Integer.valueOf(alert.getDefinitionId());
-      if (getAlertDefinition(alert.getDefinitionId())==null)
-        continue; // Ignore any removed AlertDefns 
-//      values = alert.getValues();
-      
-//      StatAlertDefinition statAlertDef = 
(StatAlertDefinition)ALERT_DEFINITIONS.get(defId);
-      
-      /*
-       * 1. check if it's system-wide.
-       * 2. if system-wide keep, it in a collection (that should get cleared 
on 
-       *    timeout). Process all alerts when notifications from all members 
are 
-       *    received. Need to check if the member leaves meanwhile. 
-       * 
-       * 1. Check if function evaluation is required?
-       * 2. If it's not required, the notification should directly be sent to 
-       *    clients.
-       */
-      
-      //if (statAlertDef.getFunctionId() != 0) {
-        /*
-         * StatAlert with alert definitions having functions
-         * assigned will get evaluated at manager side only.
-         * 
-         * Is combination of systemwide alerts with function valid? It should 
-         * be & hence such evaluation should be skipped on manager side. Or is 
-         * it to be evaluated at manager as well as aggragator?
-         */
-      //}
-      
-      //TODO: is this object required? Or earlier canbe resused?
-      StatAlertNotification alertNotification = new 
StatAlertNotification(alert, memberId);
-      
-      /*
-       * variable isSystemWide is created only for convienience, there
-       * should be an indication for the same in the alert definition. 
-       * Currently there is no systemWide definition
-       * 
-       * Evaluating system wide alerts:
-       *   1. It'll take time for aggregator to gather alerts from all members.
-       *      Member might keep joining & leaving in between. The member for 
whom 
-       *      the stat-alert value was taken might have left & new ones might 
-       *      have joined leave until all the calculations are complete. 
-       *      A disclaimer to be put that these are not exact values.
-       *   2. How would the aggregator know that it has received alerts from 
all 
-       *      the managers? Is the concept of system-wide alerts valid? 
-       *      System-wide stats might be!
-       *      
-       */
-      if (!isSystemWide) {
-        notificationObjects.add(alertNotification);
-        continue;
-      }
-      HashSet accumulatedAlertValues;
-      synchronized (alertsStore) {
-        accumulatedAlertValues = (HashSet)alertsStore.get(defId);
-        
-        if (accumulatedAlertValues == null) {
-          accumulatedAlertValues = new HashSet();
-          alertsStore.put(defId, accumulatedAlertValues);
-        }
-      }
-      synchronized (accumulatedAlertValues) {
-        accumulatedAlertValues.add(alertNotification);
-      }
-    } //for ends
-    
-    if (!notificationObjects.isEmpty()) {
-      /* TODO: should ths method send & forget or be fail-safe? */
-      sendNotifications(notificationObjects, getObjectName());
-    }
-    
-    if (logger.isDebugEnabled()) {
-      logger.debug("Exiting 
AdminDistributedSystemJmxImpl.processNotifications(StatAlert[], GemFireVM) 
*************");
-    }
-  }
-
-  private byte[] convertNotificationsDataToByteArray(ArrayList 
notificationObjects) {
-    if (logger.isDebugEnabled()) {
-      
logger.debug("AdminDistributedSystemJmxImpl#convertNotificationsDataToByteArray:
 {} notifications", notificationObjects.size());
-    }
-
-    byte[] arr = null;
-
-    try {
-      ByteArrayOutputStream byteArrStr = new ByteArrayOutputStream();
-      DataOutputStream str = new DataOutputStream(byteArrStr);
-      DataSerializer.writeArrayList(notificationObjects, str);
-      str.flush();
-      arr = byteArrStr.toByteArray();
-    } catch(IOException ex) {
-      logger.warn(LocalizedMessage.create(
-          LocalizedStrings.AdminDistributedSystem_ENCOUNTERED_AN_IOEXCEPTION_0,
-          ex.getLocalizedMessage()));
-    }
-
-    return arr;
-  }
-
-  /**
-   * An intermediate method to send notifications to the clients.
-   * 
-   * @param notificationObjects list of StatAlertNotification objects
-   */
-  private void sendNotifications(ArrayList notificationObjects, 
-      ObjectName objName) {
-    try {
-      if (logger.isDebugEnabled()) {
-        logger.debug("AdminDistributedSystemJmxImpl#sendNotifications: sending 
{} notifications", notificationObjects.size());
-      }
-      
-      byte[] notifBytes = 
convertNotificationsDataToByteArray(notificationObjects);
-      if (notifBytes!=null) {
-        Notification notif = new Notification(NOTIF_STAT_ALERT,  
-            objName, // Pass the StatNotifications
-            notificationSequenceNumber.addAndGet(1), "StatAlert 
Notifications");
-        notif.setUserData(notifBytes);
-        this.modelMBean.sendNotification(notif);
-      } // IOException handled and logged in 
convertNotificationsDataToByteArray
-
-      StringBuffer buf = new StringBuffer();
-      for (int i = 0; i < notificationObjects.size(); i ++) {
-        StatAlertNotification not = (StatAlertNotification)
-            notificationObjects.get(i);
-        buf.append(not.toString(getAlertDefinition(not.getDefinitionId())));
-      }
-//      sendEmail("Gemfire AlertNotification on Member:" + objName, 
buf.toString());
-      if (isEmailNotificationEnabled) {
-        String mess = 
LocalizedStrings.AdminDistributedSystemJmxImpl_STATISTICS_ALERT_FROM_DISTRIBUTED_SYSTEM_MEMBER_0_STATISTICS_1.toLocalizedString(new
 Object[] {objName.getCanonicalName(), buf.toString()} );
-        sendEmail(
-            EML_SUBJ_PRFX_GFE_ALERT + EML_SUBJ_ITEM_GFE_DS + getName() 
-            + " 
<"+LocalizedStrings.AdminDistributedSystemJmxImpl_STATISTICS_ALERT_FOR_MEMBER.toLocalizedString()+">",
 
-            mess);
-      }
-    } catch (javax.management.MBeanException e) {
-      logger.error(e.getMessage(), e);
-    } catch (RuntimeException e) {
-      logger.error(e.getMessage(), e);
-      throw e;
-    } catch (VirtualMachineError err) {
-      SystemFailure.initiateFailure(err);
-      // If this ever returns, rethrow the error. We're poisoned
-      // now, so don't let this thread continue.
-      throw err;
-    } catch (Error e) {
-      // Whenever you catch Error or Throwable, you must also
-      // catch VirtualMachineError (see above). However, there is
-      // _still_ a possibility that you are dealing with a cascading
-      // error condition, so you also need to check to see if the JVM
-      // is still usable:
-      SystemFailure.checkFailure();
-      logger.error(e.getMessage(), e);
-      throw e;
-    }
-  }
-  
-  /**
-   * Sends an email to the configured recipients using configured email server.
-   * The given message will be the email body. NOTE: the check whether email
-   * notfication is enabled or not should done using
-   * {@link #isEmailNotificationEnabled} before calling this method.
-   * 
-   * @param subject
-   *          subject of the email
-   * @param message
-   *          message body of the email
-   */
-  private void sendEmail(String subject, String message) {
-         if (mailManager == null) {
-           mailManager = new MailManager(mailProps);
-         }
-    this.mailManager.sendEmail(subject, message);
-  }
-
-  public void processSystemwideNotifications() {
-  }
-
-  public String getId() {
-    String myId = super.getId();
-    return MBeanUtil.makeCompliantMBeanNameProperty(myId);
-  }
-
-  /**
-   * This method is used to process ClientMembership events sent for
-   * BridgeMembership by bridge servers to all admin members.
-   * 
-   * @param senderId
-   *          id of the member that sent the ClientMembership changes for
-   *          processing (could be null)
-   * @param clientId
-   *          id of a client for which the notification was sent
-   * @param clientHost
-   *          host on which the client is/was running
-   * @param eventType
-   *          denotes whether the client Joined/Left/Crashed should be one of
-   *          ClientMembershipMessage#JOINED, ClientMembershipMessage#LEFT,
-   *          ClientMembershipMessage#CRASHED
-   */
-  @Override
-  public void processClientMembership(String senderId, String clientId,
-      String clientHost, int eventType) {
-    
logger.info(LocalizedMessage.create(LocalizedStrings.AdminDistributedSystemJmxImpl_PROCESSING_CLIENT_MEMBERSHIP_EVENT_0_FROM_1_FOR_2_RUNNING_ON_3,
 new String[] {ClientMembershipMessage.getEventTypeString(eventType), senderId, 
clientId, clientHost}));
-    try {
-      SystemMemberJmx systemMemberJmx = null;
-      CacheVm[] cacheVms = getCacheVms();
-      
-      for (CacheVm cacheVm : cacheVms) {
-        if (cacheVm.getId().equals(senderId) && 
-            cacheVm instanceof CacheServerJmxImpl) {
-          systemMemberJmx = (CacheServerJmxImpl) cacheVm;
-          break;
-        }
-      }
-      
-      if (systemMemberJmx == null) {
-        SystemMember[] appVms = getSystemMemberApplications();
-        
-        for (SystemMember appVm : appVms) {
-          if (appVm.getId().equals(senderId) && 
-              appVm instanceof SystemMemberJmxImpl) {
-            systemMemberJmx = (SystemMemberJmxImpl) appVm;
-            break;
-          }
-        }
-        
-      }
-
-      if (systemMemberJmx != null) {
-        systemMemberJmx.handleClientMembership(clientId, eventType);
-      }
-    } catch (AdminException e) {
-      logger.error(LocalizedMessage.create(
-          
LocalizedStrings.AdminDistributedSystemJmxImpl_FAILED_TO_PROCESS_CLIENT_MEMBERSHIP_FROM_0_FOR_1,
-              new Object[] { senderId, clientId }), e);
-      return;
-    } catch (RuntimeOperationsException e) {
-      logger.warn(e.getMessage(), e);//failed to send notification
-    }
-  }
-
-  public String getAlertLevelAsString() {
-    return super.getAlertLevelAsString();
-  }
-  
-  public void setAlertLevelAsString(String level) {
-    String newLevel = level != null ? level.trim() : null;
-    try {
-      super.setAlertLevelAsString(newLevel);
-    } catch (IllegalArgumentException e) {
-      throw new RuntimeMBeanException(e, e.getMessage());
-    }
-  }
-
-  /**
-   * Finds the member as per details in the given event object and passes on
-   * this event for handling the cache creation.
-   * 
-   * @param event
-   *          event object corresponding to the creation of the cache
-   */
-  public void handleCacheCreateEvent(SystemMemberCacheEvent event) {
-    String memberId = event.getMemberId();
-    SystemMemberJmx systemMemberJmx = (SystemMemberJmx) 
findCacheOrAppVmById(memberId);
-    
-    if (systemMemberJmx != null) {
-      systemMemberJmx.handleCacheCreate(event);
-    }
-    
-  }
-
-  /**
-   * Finds the member as per details in the given event object and passes on
-   * this event for handling the cache closure.
-   * 
-   * @param event
-   *          event object corresponding to the closure of the cache
-   */
-  public void handleCacheCloseEvent(SystemMemberCacheEvent event) {
-    String memberId = event.getMemberId();
-    SystemMemberJmx systemMemberJmx = (SystemMemberJmx) 
findCacheOrAppVmById(memberId);
-    
-    if (systemMemberJmx != null) {
-      systemMemberJmx.handleCacheClose(event);
-    }
-    
-  }
-
-  /**
-   * Finds the member as per details in the given event object and passes on
-   * this event for handling the region creation.
-   * 
-   * @param event
-   *          event object corresponding to the creation of a region
-   */
-  public void handleRegionCreateEvent(SystemMemberRegionEvent event) {
-    String memberId = event.getMemberId();
-    SystemMemberJmx systemMemberJmx = (SystemMemberJmx) 
findCacheOrAppVmById(memberId);
-    
-    if (systemMemberJmx != null) {
-      systemMemberJmx.handleRegionCreate(event);
-    }
-  }  
-  
-  /**
-   * Finds the member as per details in the given event object and passes on 
-   * this event for handling the region loss.
-   * 
-   * @param event
-   *          event object corresponding to the loss of a region
-   */
-  public void handleRegionLossEvent(SystemMemberRegionEvent event) {
-    String memberId = event.getMemberId();
-    SystemMemberJmx systemMemberJmx = (SystemMemberJmx) 
findCacheOrAppVmById(memberId);
-    
-    if (systemMemberJmx != null) {
-      systemMemberJmx.handleRegionLoss(event);
-    }
-  }
-
-  @Override
-  public void setDisableAutoReconnect(boolean newValue) {
-    getConfig().setDisableAutoReconnect(newValue);
-  }
-
-  @Override
-  public boolean getDisableAutoReconnect() {
-    return getConfig().getDisableAutoReconnect();
-  }  
-  
-}
-
-class ProcessSystemwideStatAlertsNotification extends TimerTask {
-  private StatAlertsAggregator aggregator;
-  
-  ProcessSystemwideStatAlertsNotification(StatAlertsAggregator aggregator) {
-    this.aggregator = aggregator;
-  }
-  
-  @Override
-  public void run() {
-    aggregator.processSystemwideNotifications();
-  }
-  
-}
-
-/**
- * Implementation of SystemMemberCacheListener used for listening to events:
- * <ol> <li> Cache Created </li>
- * <li> Cache Closed </li>
- * <li> Region Created </li>
- * <li> Region Loss </li>
- * </ol>
- * 
- */
-class CacheAndRegionListenerImpl implements SystemMemberCacheListener {
-  private AdminDistributedSystemJmxImpl adminDS;
-
-  /**
-   * Csontructor to create CacheAndRegionListenerImpl
-   * 
-   * @param adminDSResource
-   *          instance of AdminDistributedSystemJmxImpl
-   */
-  CacheAndRegionListenerImpl(AdminDistributedSystemJmxImpl adminDSResource) {
-    this.adminDS = adminDSResource;
-  }
-  
-  /**
-   * See SystemMemberCacheListener#afterCacheClose(SystemMemberCacheEvent)
-   */
-  public void afterCacheClose(SystemMemberCacheEvent event) {
-    adminDS.handleCacheCloseEvent(event);
-  }
-  
-  /**
-   * See SystemMemberCacheListener#afterCacheCreate(SystemMemberCacheEvent)
-   */
-  public void afterCacheCreate(SystemMemberCacheEvent event) {
-    adminDS.handleCacheCreateEvent(event);
-  }
-  
-  /**
-   * See SystemMemberCacheListener#afterRegionCreate(SystemMemberCacheEvent)
-   */
-  public void afterRegionCreate(SystemMemberRegionEvent event) {
-    adminDS.handleRegionCreateEvent(event);    
-  }
-  
-  /**
-   * See SystemMemberCacheListener#afterRegionLoss(SystemMemberCacheEvent)
-   */
-  public void afterRegionLoss(SystemMemberRegionEvent event) {
-    adminDS.handleRegionLossEvent(event);
-  }  
-}
-

Reply via email to