/src/edu/ucsb/nceas/metacat/dataone/hazelcast/HazelcastService.java - Annotate - Metacat - Ecoinformatics Redmine

metacat/src/edu/ucsb/nceas/metacat/dataone/hazelcast/HazelcastService.java @ 6437

-            cjones
+/**
  *  '$RCSfile$'
  *    Purpose: Implements a service for managing a Hazelcast cluster member
  *  Copyright: 2011 Regents of the University of California and the
  *             National Center for Ecological Analysis and Synthesis
  *    Authors: Christopher Jones
+ *
  *   '$Author$'
  *     '$Date$'
  * '$Revision$'
+ *
  * This program is free software; you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by
  * the Free Software Foundation; either version 2 of the License, or
  * (at your option) any later version.
+ *
  * This program is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  * GNU General Public License for more details.
+ *
  * You should have received a copy of the GNU General Public License
  * along with this program; if not, write to the Free Software
  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  */
-            leinfelder
+package edu.ucsb.nceas.metacat.dataone.hazelcast;
             cjones
 import org.apache.log4j.Logger;
-            cjones
+import com.hazelcast.config.Config;
-            leinfelder
+import com.hazelcast.config.FileSystemXmlConfig;
-            cjones
+import com.hazelcast.core.Hazelcast;
 import com.hazelcast.core.InstanceEvent;
 import com.hazelcast.core.InstanceListener;
-            cjones
+import edu.ucsb.nceas.metacat.properties.PropertyService;
-            cjones
+import edu.ucsb.nceas.metacat.shared.BaseService;
 import edu.ucsb.nceas.metacat.shared.ServiceException;
 /**
  * The Hazelcast service enables Metacat as a Hazelcast cluster member
  */
 public class HazelcastService extends BaseService
   implements InstanceListener {
   /* The instance of the logging class */
   private static Logger logMetacat = Logger.getLogger(HazelcastService.class);
   /* The singleton instance of the hazelcast service */
-            cjones
+  private static HazelcastService hzService = null;
             cjones
-            cjones
+  /* The Hazelcast configuration */
   private Config hzConfig;
             cjones
   /*
    * Constructor: Creates an instance of the hazelcast service. Since
    * this uses a singleton pattern, use getInstance() to gain the instance.
    */
   private HazelcastService() {
     super();
     _serviceName="HazelcastService";
     try {
-            cjones
+      init();
             cjones
     } catch (ServiceException se) {
-            leinfelder
+      logMetacat.error("There was a problem creating the HazelcastService. " +
-            cjones
+                       "The error message was: " + se.getMessage());
+    }
+  }
   /**
    *  Get the instance of the HazelcastService that has been instantiated,
    *  or instantiate one if it has not been already.
+   *
    * @return hazelcastService - The instance of the hazelcast service
    */
   public static HazelcastService getInstance(){
-            cjones
+    if ( hzService == null ) {
             cjones
-            cjones
+      hzService = new HazelcastService();
             cjones
+    }
-            cjones
+    return hzService;
             cjones
   /**
-            cjones
+   * Initializes the Hazelcast service
-            cjones
+   */
-            cjones
+  public void init() throws ServiceException {
             cjones
     logMetacat.debug("HazelcastService.doRefresh() called.");
-            cjones
+    try {
-            leinfelder
+    	String configFileName = PropertyService.getProperty("dataone.hazelcast.configFilePath");
 //    	System.setProperty("hazelcast.config", configFileName);
 		Config config = new FileSystemXmlConfig(configFileName);
 		Hazelcast.init(config);
     } catch (Exception e) {
       String msg = e.getMessage();
-            cjones
+      logMetacat.error(msg);
       throw new ServiceException(msg);
             cjones
             cjones
-            cjones
+    return;
+  }
   /**
    * Indicate whether or not this service is refreshable.
+   *
    * @return refreshable - the boolean refreshable status
    */
   public boolean refreshable() {
-            cjones
+    // TODO: Determine the consequences of restarting the Hazelcast instance
-            cjones
+    // Set this to true if it's okay to drop from the cluster, lose the maps,
     // and start back up again
     return false;
             cjones
+  }
   /**
    * Stop the HazelcastService. When stopped, the service will no longer
    * respond to requests.
    */
   public void stop() throws ServiceException {
     Hazelcast.getLifecycleService().shutdown();
+  }
   /**
    * Listen for new Hazelcast member events
    */
-            cjones
+  @Override
-            cjones
+  public void instanceCreated(InstanceEvent event) {
-            cjones
+    logMetacat.info("New Hazelcast instance created: " +
       event.getInstance().getId() + ", " +
       event.getInstance().getInstanceType());
             cjones
-            cjones
+  @Override
-            cjones
+  public void instanceDestroyed(InstanceEvent event) {
-            cjones
+    logMetacat.info("Hazelcast instance removed: " +
         event.getInstance().getId() + ", " +
         event.getInstance().getInstanceType());
             cjones
             cjones
   /**
    * Refresh the Hazelcast service by restarting it
    */
   @Override
-            cjones
+  protected void doRefresh() throws ServiceException {
-            cjones
+    // TODO: verify that the correct config file is still used
-            cjones
+    Hazelcast.getLifecycleService().restart();
             cjones
             cjones
             cjones

Project

General

Profile

Metacat