User: slaboure Date: 01/11/09 14:43:28 Modified: src/main/org/jboss/ha/framework/server HAPartitionImpl.java Log: Added some basic methods used for SFSB support: - allow to get the current view - rebind instead of bind to JNDI Revision Changes Path 1.7 +11 -4 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.6 retrieving revision 1.7 diff -u -r1.6 -r1.7 --- HAPartitionImpl.java 2001/10/20 20:51:33 1.6 +++ HAPartitionImpl.java 2001/11/09 22:43:28 1.7 @@ -56,10 +56,10 @@ * * @author [EMAIL PROTECTED] * @author [EMAIL PROTECTED] - * @version $Revision: 1.6 $ + * @version $Revision: 1.7 $ * * <p><b>Revisions:</b><br> - */ +*/ public class HAPartitionImpl extends RpcDispatcher implements HAPartition, MembershipListener, MessageListener { protected HashMap rpcHandlers = new HashMap (); @@ -150,7 +150,7 @@ // StringRefAddr addr = new StringRefAddr ("nns", jndiName); Reference ref = new Reference ( classType.getName (), addr, NonSerializableFactory.class.getName (), null); - ctx.bind (n.get (0), ref); + ctx.rebind (n.get (0), ref); } public void start () throws Exception @@ -184,6 +184,7 @@ public void close () throws Exception { + log.info ("Closing partition " + partitionName); // Stop the DRM and DS services // try {this.replicantManager.stop ();} catch (Exception printed) {printed.printStackTrace ();} @@ -192,6 +193,7 @@ try {channel.Close ();} catch (Exception printed) {printed.printStackTrace ();} new InitialContext ().unbind ("/HAPartition/" + partitionName); + log.info ("Partition " + partitionName + " closed."); } public String getNodeName () @@ -218,6 +220,11 @@ { return this.currentViewId; } + + public Vector getCurrentView () + { + return this.members; + } // *************************** // *************************** @@ -388,7 +395,7 @@ // we update the view id // this.currentViewId = newView.GetVid().GetId(); - log.info("new view accepted: " + currentViewId); + log.info("new view accepted: " + currentViewId + " (" + newView.GetMembers () + ")"); if (this.members == null) {
_______________________________________________ Jboss-development mailing list [EMAIL PROTECTED] https://lists.sourceforge.net/lists/listinfo/jboss-development