ClusterPartitionMBean.java |
/* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. */ package org.jboss.ha.framework.server; import java.net.InetAddress; import java.util.Vector; import javax.management.ObjectName; import org.jboss.ha.framework.interfaces.HAPartition; import org.jboss.mx.util.ObjectNameFactory; import org.w3c.dom.Element; /** * Management Bean for Cluster HAPartitions. It will start a JGroups * channel and initialize the ReplicantManager and DistributedStateService. * * @author <a href="mailto:bill@burkecentral.com">Bill Burke</a>. * @author <a href="mailto:sacha.labourey@cogito-info.ch">Sacha Labourey</a>. * @version $Revision: 1.19 $ * * <p><b>Revisions:</b><br> */ public interface ClusterPartitionMBean extends org.jboss.system.ServiceMBean { ObjectName OBJECT_NAME = ObjectNameFactory.create("jboss:service=ClusterPartition"); /** * Name of the partition being built. All nodes/services belonging to * a partition with the same name are clustered together. */ String getPartitionName(); void setPartitionName(String newName); /** * Get JGroups property string a la JDBC * see <a href="http://www.jgroups.com/">JGroups web site for more information</a> */ String getPartitionProperties(); // i.e. JGroups properties void setPartitionProperties(String newProps); /** A write-only attribute that allows for an xml specification of the *PartitionProperties string. For example, a string like: UDP(mcast_addr=228.1.2.3):PING(timeout=2000):MERGE2(min_interval=5000;max_interval=10000):FD" * would be specified in xml as: <JGProps> <UDP mcast_addr="228.1.2.3" /> <PING timeout="2000" /> <MERGE2 min_interval="5000" max_interval="10000" /> <FD /> </JGProps> */ void setPartitionConfig(Element config); /** * Uniquely identifies this node. MUST be unique accros the whole cluster! * Cannot be changed once the partition has been started (otherwise an exception is thrown) */ String getNodeName(); void setNodeName(String node) throws Exception; /** * The node address used to generate the node name */ InetAddress getNodeAddress(); void setNodeAddress(InetAddress address); /** The version of JGroups this is running on */ String getJGroupsVersion(); /* Number of milliseconds to wait until state has been transferred. Increase this value for large states 0 = wait forever */ long getStateTransferTimeout(); void setStateTransferTimeout(long timeout); /** Max time (in ms) to wait for <em>synchronous</em> group method calls * ({@link HAPartition#callMethodOnCluster(String, String, Object[], Class[], boolean)}) */ long getMethodCallTimeout(); void setMethodCallTimeout(long timeout); // boolean getChannelDebugger(); // void setChannelDebugger(boolean flag); /** * Determine if deadlock detection is enabled */ boolean getDeadlockDetection(); void setDeadlockDetection(boolean doit); /** Access to the underlying HAPartition without going through JNDI * * @return the HAPartition for the cluster service */ HAPartition getHAPartition (); /** Return the list of member nodes that built from the current view * @return A Vector Strings representing the host:port values of the nodes */ Vector getCurrentView(); String showHistory (); String showHistoryAsXML (); void startChannelDebugger(); void startChannelDebugger(boolean accumulative); void stopChannelDebugger(); }
ClusterPartitionMBean.java |