public ServiceMBeanSupport() 
{
   
      // can not call this(Class) because we need to call getClass()
      this.log = Logger.getLogger(getClass().getName());
      log.trace("Constructing");
}

Construct a ServiceMBeanSupport.

Sets up logging.

 public ServiceMBeanSupport(Class type) 
{
      this(type.getName());
}

Construct a ServiceMBeanSupport.

Sets up logging.

Parameters:

type - The class type to determine category name from.

 public ServiceMBeanSupport(String category) 
{
      this(Logger.getLogger(category));
}

Construct a ServiceMBeanSupport.

Sets up logging.

Parameters:

category - The logger category name.

 public ServiceMBeanSupport(Logger log) 
{
      this.log = log;
      log.trace("Constructing");
}

Construct a ServiceMBeanSupport.

Parameters:

log - The logger to use.

 public  void create() throws Exception 
{
      if (controllerContext != null)
         pojoChange(ControllerState.CREATE);
      else if (serviceName != null && isJBossInternalLifecycleExposed)
         server.invoke(ServiceController.OBJECT_NAME, "create", new Object[] { serviceName }, SERVICE_CONTROLLER_SIG);
      else
         jbossInternalCreate();
}

 protected  void createService() throws Exception 
{

}

Sub-classes should override this method to provide custum 'create' logic.

This method is empty, and is provided for convenience when concrete service classes do not need to perform anything specific for this state change.

 public  void destroy() 
{
      try
      {
         if (controllerContext != null)
            pojoChange(ControllerState.CONFIGURED);
         else if (serviceName != null && isJBossInternalLifecycleExposed)
            server.invoke(ServiceController.OBJECT_NAME, "destroy", new Object[] { serviceName }, SERVICE_CONTROLLER_SIG);
         else
            jbossInternalDestroy();
      }
      catch (Throwable t)
      {
         log.warn("Error in destroy " + jbossInternalDescription(), t);
      }
}

 protected  void destroyService() throws Exception 
{

}

Sub-classes should override this method to provide custum 'destroy' logic.

This method is empty, and is provided for convenience when concrete service classes do not need to perform anything specific for this state change.

 public DeploymentInfo getDeploymentInfo() throws JMException 
{
      Object[] args = {serviceName};
      String[] sig = {serviceName.getClass().getName()};
      DeploymentInfo sdi = (DeploymentInfo) server.invoke(SARDeployerMBean.OBJECT_NAME,
         "getService", args, sig);
      return sdi;
}

Provide access to the service DeploymentInfo. This is only available after the service has passed its create step.

 public Logger getLog() 
{
      return log;
}

 public String getName() 
{
      // TODO: Check if this gets called often, if so cache this or remove if not used
      // use the logger so we can better be used as a delegate instead of sub-class
      return org.jboss.util.Classes.stripPackageName(log.getName());
}

Use the short class name as the default for the service name.

 protected long getNextNotificationSequenceNumber() 
{
      return nextNotificationSequenceNumber();
}

The getNextNotificationSequenceNumber method returns the next sequence number for use in notifications.

 protected ObjectName getObjectName(MBeanServer server,
    ObjectName name) throws MalformedObjectNameException 
{
      return name;
}

Sub-classes should override this method if they only need to set their object name during MBean pre-registration.

 public MBeanServer getServer() 
{
      return server;
}

 public ObjectName getServiceName() 
{
      return serviceName;
}

 public int getState() 
{
      return state;
}

 public String getStateString() 
{
      return states[state];
}

 protected  void jbossInternalCreate() throws Exception 
{
      if (state == CREATED || state == STARTING || state == STARTED
         || state == STOPPING || state == STOPPED)
      {
         log.debug("Ignoring create call; current state is " + getStateString());
         return;
      }
      log.debug("Creating " + jbossInternalDescription());
      try
      {
         createService();
         state = CREATED;
      }
      catch (Exception e)
      {
         log.debug("Initialization failed " + jbossInternalDescription(), e);
         throw e;
      }
      log.debug("Created " + jbossInternalDescription());
}

 protected String jbossInternalDescription() 
{
      if (serviceName != null)
         return serviceName.toString();
      else
         return getName();
}

 protected  void jbossInternalDestroy() 
{
      if (state == DESTROYED)
      {
         log.debug("Ignoring destroy call; current state is " + getStateString());
         return;
      }
      if (state == STARTED)
      {
         log.debug("Destroy requested before stop, calling stop now");
         stop();
      }
      log.debug("Destroying " + jbossInternalDescription());
      try
      {
         destroyService();
      }
      catch (Throwable t)
      {
         log.warn("Destroying failed " + jbossInternalDescription(), t);
      }
      state = DESTROYED;
      log.debug("Destroyed " + jbossInternalDescription());
}

 public  void jbossInternalLifecycle(String method) throws Exception 
{
      if (method == null)
         throw new IllegalArgumentException("Null method name");
      if (method.equals("create"))
         jbossInternalCreate();
      else if (method.equals("start"))
         jbossInternalStart();
      else if (method.equals("stop"))
         jbossInternalStop();
      else if (method.equals("destroy"))
         jbossInternalDestroy();
      else
         throw new IllegalArgumentException("Unknown lifecyle method " + method);
}

 protected  void jbossInternalStart() throws Exception 
{
      if (state == STARTING || state == STARTED || state == STOPPING)
      {
         log.debug("Ignoring start call; current state is " + getStateString());
         return;
      }
      if (state != CREATED && state != STOPPED && state != FAILED)
      {
         log.debug("Start requested before create, calling create now");         
         create();
      }
      state = STARTING;
      sendStateChangeNotification(STOPPED, STARTING, getName() + " starting", null);
      log.debug("Starting " + jbossInternalDescription());
      try
      {
         startService();
      }
      catch (Exception e)
      {
         state = FAILED;
         sendStateChangeNotification(STARTING, FAILED, getName() + " failed", e);
         log.debug("Starting failed " + jbossInternalDescription(), e);
         throw e;
      }
      state = STARTED;
      sendStateChangeNotification(STARTING, STARTED, getName() + " started", null);
      log.debug("Started " + jbossInternalDescription());
}

 protected  void jbossInternalStop() 
{
      if (state != STARTED)
      {
         log.debug("Ignoring stop call; current state is " + getStateString());
         return;
      }
      state = STOPPING;
      sendStateChangeNotification(STARTED, STOPPING, getName() + " stopping", null);
      log.debug("Stopping " + jbossInternalDescription());
      try
      {
         stopService();
      }
      catch (Throwable e)
      {
         state = FAILED;
         sendStateChangeNotification(STOPPING, FAILED, getName() + " failed", e);
         log.warn("Stopping failed " + jbossInternalDescription(), e);
         return;
      }
      state = STOPPED;
      sendStateChangeNotification(STOPPING, STOPPED, getName() + " stopped", null);
      log.debug("Stopped " + jbossInternalDescription());
}

 protected  void pojoChange(ControllerState state) 
{
      Controller controller = controllerContext.getController();
      try
      {
         controller.change(controllerContext, state);
      }
      catch (RuntimeException e)
      {
         throw e;
      }
      catch (Error e)
      {
         throw e;
      }
      catch (Throwable t)
      {
         throw new RuntimeException("Error changing state of " + controllerContext.getName() + " to " + state.getStateString(), t);
      }
}

 public  void pojoCreate() throws Exception 
{
      jbossInternalCreate();
}

 public  void pojoDestroy() throws Exception 
{
      jbossInternalDestroy();
}

 public  void pojoStart() throws Exception 
{
      jbossInternalStart();
}

 public  void pojoStop() throws Exception 
{
      jbossInternalStop();
}

 public  void postDeregister() 
{
      server = null;
      serviceName = null;
      state = UNREGISTERED;
}

 public  void postRegister(Boolean registrationDone) 
{
      if (!registrationDone.booleanValue())
      {
         log.info( "Registration is not done - > stop" );
         stop();
      }
      else
      {
         state = REGISTERED;
         // This is for backwards compatibility - see whether jbossInternalLifecycle is exposed
         try
         {
            MBeanInfo info = server.getMBeanInfo(serviceName);
            MBeanOperationInfo[] ops = info.getOperations();
            for (int i = 0; i <  ops.length; ++i)
            {
               if (ops[i] != null && ServiceController.JBOSS_INTERNAL_LIFECYCLE.equals(ops[i].getName()))
               {
                  isJBossInternalLifecycleExposed = true;
                  break;
               }
            }
         }
         catch (Throwable t)
         {
            log.warn("Unexcepted error accessing MBeanInfo for " + serviceName, t);
         }
      }
}

 public  void preDeregister() throws Exception 
{

}

 public ObjectName preRegister(MBeanServer server,
    ObjectName name) throws Exception 
{
      this.server = server;
      serviceName = getObjectName(server, name);
      return serviceName;
}

Callback method of MBeanRegistration before the MBean is registered at the JMX Agent.

Attention: Always call this method when you overwrite it in a subclass because it saves the Object Name of the MBean.

 public  void setKernelControllerContext(KernelControllerContext controllerContext) throws Exception 
{
      this.controllerContext = controllerContext;
}

 public  void start() throws Exception 
{
      if (controllerContext != null)
         pojoChange(ControllerState.START);
      else if (serviceName != null && isJBossInternalLifecycleExposed)
         server.invoke(ServiceController.OBJECT_NAME, "start", new Object[] { serviceName }, SERVICE_CONTROLLER_SIG);
      else
         jbossInternalStart();
}

 protected  void startService() throws Exception 
{

}

Sub-classes should override this method to provide custum 'start' logic.

This method is empty, and is provided for convenience when concrete service classes do not need to perform anything specific for this state change.

 public  void stop() 
{
      try
      {
         if (controllerContext != null)
            pojoChange(ControllerState.CREATE);
         else if (serviceName != null && isJBossInternalLifecycleExposed)
            server.invoke(ServiceController.OBJECT_NAME, "stop", new Object[] { serviceName }, SERVICE_CONTROLLER_SIG);
         else
            jbossInternalStop();
      }
      catch (Throwable t)
      {
         log.warn("Error in stop " + jbossInternalDescription(), t);
      }
}

 protected  void stopService() throws Exception 
{

}

Sub-classes should override this method to provide custum 'stop' logic.

This method is empty, and is provided for convenience when concrete service classes do not need to perform anything specific for this state change.

 public  void unsetKernelControllerContext(KernelControllerContext controllerContext) throws Exception 
{
      this.controllerContext = null;
}