[jboss-cvs] JBossAS SVN: r76051 - trunk/cluster/src/main/org/jboss/ha/jmx.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Mon Jul 21 01:49:57 EDT 2008


Author: bstansberry at jboss.com
Date: 2008-07-21 01:49:57 -0400 (Mon, 21 Jul 2008)
New Revision: 76051

Modified:
   trunk/cluster/src/main/org/jboss/ha/jmx/HAServiceMBeanSupport.java
Log:
[JBAS-5659] Allow overrides of values by mod_cluster singleton

Modified: trunk/cluster/src/main/org/jboss/ha/jmx/HAServiceMBeanSupport.java
===================================================================
--- trunk/cluster/src/main/org/jboss/ha/jmx/HAServiceMBeanSupport.java	2008-07-21 05:46:13 UTC (rev 76050)
+++ trunk/cluster/src/main/org/jboss/ha/jmx/HAServiceMBeanSupport.java	2008-07-21 05:49:57 UTC (rev 76051)
@@ -202,19 +202,34 @@
    {
       // method no longer used by base implementation
    }
+   
+   /**
+    * Returns the object upon which incoming RPC invocations will be made.
+    * 
+    * @return the default implementation returns <code>this</code>
+    */
+   protected Object getRPCHandler()
+   {
+      return this;
+   }
 
    protected void registerRPCHandler()
    {
       if (isRegisterThreadContextClassLoader())
-         clusterPartition.registerRPCHandler(getServiceHAName(), this, Thread.currentThread().getContextClassLoader());
+         clusterPartition.registerRPCHandler(getServiceHAName(), getRPCHandler(), Thread.currentThread().getContextClassLoader());
       else
-         clusterPartition.registerRPCHandler(getServiceHAName(), this);         
+         clusterPartition.registerRPCHandler(getServiceHAName(), getRPCHandler());         
    }
 
    protected void unregisterRPCHandler()
    {
       clusterPartition.unregisterRPCHandler(getServiceHAName(), this);
    }
+   
+   protected Serializable getReplicant()
+   {
+      return REPLICANT_TOKEN;
+   }
 
    protected void registerDRMListener() throws Exception
    {
@@ -249,7 +264,7 @@
       drm.registerListener(getServiceHAName(), drmListener);
 
       // this ensures that the DRM knows that this node has the MBean deployed 
-      drm.add(getServiceHAName(), REPLICANT_TOKEN);
+      drm.add(getServiceHAName(), getReplicant());
    }
 
    protected void unregisterDRMListener() throws Exception




More information about the jboss-cvs-commits mailing list