[jboss-cvs] JBossAS SVN: r61769 - branches/Branch_4_2/cluster/src/main/org/jboss/ha/framework/server.

[jboss-cvs-commits at lists.jboss.org]

Author: bstansberry at jboss.com
Date: 2007-03-27 22:39:07 -0400 (Tue, 27 Mar 2007)
New Revision: 61769

Modified:
   branches/Branch_4_2/cluster/src/main/org/jboss/ha/framework/server/ClusterPartition.java
Log:
[JBAS-4258] Invoke Channel.down via reflection to allow future upgrade to JGroups 2.5

Modified: branches/Branch_4_2/cluster/src/main/org/jboss/ha/framework/server/ClusterPartition.java
===================================================================
--- branches/Branch_4_2/cluster/src/main/org/jboss/ha/framework/server/ClusterPartition.java	2007-03-28 00:57:01 UTC (rev 61768)
+++ branches/Branch_4_2/cluster/src/main/org/jboss/ha/framework/server/ClusterPartition.java	2007-03-28 02:39:07 UTC (rev 61769)
@@ -22,6 +22,7 @@
 package org.jboss.ha.framework.server;
 
 
+import java.lang.reflect.Method;
 import java.net.InetAddress;
 import java.rmi.dgc.VMID;
 import java.rmi.server.UID;
@@ -369,7 +370,13 @@
 
       java.util.HashMap staticNodeName = new java.util.HashMap();
       staticNodeName.put("additional_data", this.nodeName.getBytes());
-      this.channel.down(new org.jgroups.Event(org.jgroups.Event.CONFIG, staticNodeName));
+      
+      // JBAS-4258 -- invoke via reflection to allow upgrade to JGroups 2.5
+      Class[] paramTypes = new Class[]{org.jgroups.Event.class};
+      Method downMethod = JChannel.class.getDeclaredMethod("down", paramTypes);
+      Object[] params = { new org.jgroups.Event(org.jgroups.Event.CONFIG, staticNodeName) };
+      downMethod.invoke(channel, params);
+
       this.channel.getProtocolStack().flushEvents(); // temporary fix for JG bug (808170) TODO: REMOVE ONCE JGROUPS IS FIXED
 
       log.debug("Starting ClusterPartition: " + partitionName);