User: slaboure
Date: 01/12/29 08:20:13
Modified: src/main/org/jboss/ha/framework/server ClusterPartition.java
HAPartitionImpl.java
Log:
Propagate MBeanServer reference
Revision Changes Path
1.9 +2 -2
jbossmx/src/main/org/jboss/ha/framework/server/ClusterPartition.java
Index: ClusterPartition.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmx/src/main/org/jboss/ha/framework/server/ClusterPartition.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -u -r1.8 -r1.9
--- ClusterPartition.java 2001/11/26 15:52:55 1.8
+++ ClusterPartition.java 2001/12/29 16:20:12 1.9
@@ -23,7 +23,7 @@
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Bill Burke</a>.
* @author <a href="mailto:[EMAIL PROTECTED]";>Sacha Labourey</a>.
- * @version $Revision: 1.8 $
+ * @version $Revision: 1.9 $
*
* <p><b>Revisions:</b><br>
*/
@@ -138,7 +138,7 @@
channel.SetOpt(Channel.AUTO_GETSTATE, new Boolean(true));
log.info("Creating HAPartition...");
- partition = new HAPartitionImpl(partitionName, channel, deadlock_detection);
+ partition = new HAPartitionImpl(partitionName, channel, deadlock_detection,
getServer());
log.info("...Initing HAPartition...");
partition.init();
1.11 +11 -2
jbossmx/src/main/org/jboss/ha/framework/server/HAPartitionImpl.java
Index: HAPartitionImpl.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmx/src/main/org/jboss/ha/framework/server/HAPartitionImpl.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -u -r1.10 -r1.11
--- HAPartitionImpl.java 2001/11/26 14:20:01 1.10
+++ HAPartitionImpl.java 2001/12/29 16:20:13 1.11
@@ -14,6 +14,7 @@
import javax.naming.Context;
import javax.naming.StringRefAddr;
import javax.naming.InitialContext;
+import javax.management.MBeanServer;
import JavaGroups.MethodCall;
@@ -32,7 +33,7 @@
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Sacha Labourey</a>.
* @author <a href="mailto:[EMAIL PROTECTED]";>Bill Burke</a>.
- * @version $Revision: 1.10 $
+ * @version $Revision: 1.11 $
*
* <p><b>Revisions:</b><br>
*/
@@ -65,10 +66,18 @@
protected long currentViewId = -1;
+ protected MBeanServer server = null;
+
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
+ public HAPartitionImpl (String partitionName, JavaGroups.JChannel channel,
boolean deadlock_detection, MBeanServer server) throws Exception
+ {
+ this (partitionName, channel, deadlock_detection);
+ this.server = server;
+ }
+
public HAPartitionImpl (String partitionName, JavaGroups.JChannel channel,
boolean deadlock_detection) throws Exception
{
super(channel, null, null, new Object (), false); // init RpcDispatcher with
a fake target object
@@ -99,7 +108,7 @@
// Create the DS and link it to this HAPartition
//
log.debug ("create distributed state");
- this.dsManager = new DistributedStateImpl (this);
+ this.dsManager = new DistributedStateImpl (this, this.server);
log.debug ("init distributed state service");
this.dsManager.init ();
log.debug ("bind distributed state service");
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
