|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.objectweb.jonas.management.cluster.BaseCluster
public abstract class BaseCluster
Implements basics for cluster management. To be extended by the different cluster types. It implements cluster state transition diagram based on the members's state. A member is represented by a ClusterMember class instance.
ClusterMember
Nested Class Summary | |
---|---|
class |
BaseCluster.DeployThread
|
Field Summary | |
---|---|
protected ClusterFactory |
cf
ClusterFactory that created this Cluster |
protected DomainMonitor |
dm
ref to the domainMonitor |
protected JmxService |
jmx
ref to the Jmx Service |
protected static org.objectweb.util.monolog.api.Logger |
logger
domain management logger |
protected java.util.Map |
members
The list of ClusterMember objects that compose this Cluster Key = name of the Member. |
protected java.lang.String |
name
The name of this Cluster. |
protected javax.management.ObjectName |
objectName
MBean OBJECT_NAME |
protected int |
state
The cluster state |
static int |
STATE_DOWN
All the members are in STOPPED state |
static int |
STATE_FAILED
All the members are in FAILED state |
static int |
STATE_INIT
This is the initial state, all members are in INITIAL state |
static int |
STATE_PARTIALLY_DOWN
At least one members is in STOPPED state, there is no failed member, there is no running memeber |
static int |
STATE_PARTIALLY_FAILED
At least one members is in FAILED state |
static int |
STATE_PARTIALLY_UP
At least one members is in RUNNING state, there is no failed member |
static int |
STATE_UNKNOWN
No member in FAILED state, no member in RUNNING state, no memeber in STOPPED state The members' state may be UNREACHABLE or UNKNOWN |
static int |
STATE_UP
All the members are in RUNNING state |
Constructor Summary | |
---|---|
BaseCluster(ClusterFactory cf)
Constructor |
Method Summary | |
---|---|
boolean |
addMember(ClusterMember m)
Add a Member to the Cluster |
void |
addServer(java.lang.String name,
java.lang.String[] urls,
java.lang.String clusterd)
Deprecated. addServer(String, String[], String, String, String) |
void |
addServer(java.lang.String svname,
java.lang.String[] urls,
java.lang.String cdn,
java.lang.String username,
java.lang.String password)
MBean operation Add a server in the cluster (jonasAdmin) - this is only called for LogicalCluster |
abstract ClusterMember |
createClusterMember(java.lang.String svname,
ServerProxy proxy)
Create a new ClusterMember. |
void |
deployModule(java.lang.String file)
MBean operation Deploy a module on all nodes. |
java.lang.String[] |
getMembers()
|
java.lang.String |
getName()
|
int |
getNbMembers()
|
java.lang.String |
getObjectName()
|
J2EEServer |
getServer(java.lang.String name)
Get a server by its name. |
ServerProxy |
getServerProxy(java.lang.String name)
Get a server by its name. |
java.util.Collection |
getServerProxyList()
|
java.lang.String |
getState()
Get the Cluster State |
abstract java.lang.String |
getType()
|
void |
removeServer(java.lang.String svname)
MBean operation Remove a server from the cluster (jonasAdmin) |
javax.management.ObjectName |
setName(java.lang.String name)
Set the MBean name, that may be unknown when constructor is called. |
void |
startit()
MBean operation Start all cluster nodes. |
void |
stopit()
MBean operation Stop all cluster nodes. |
void |
undeployModule(java.lang.String file)
MBean operation Undeploy a module on all nodes. |
void |
uploadDeployModule(java.lang.String file,
boolean repl)
MBean operation Upload adn deploy a module on all nodes. |
void |
uploadFile(java.lang.String file,
boolean repl)
MBean operation Upload a file on all nodes. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected java.lang.String name
protected javax.management.ObjectName objectName
protected java.util.Map members
protected ClusterFactory cf
protected int state
public static final int STATE_INIT
public static final int STATE_UP
public static final int STATE_DOWN
public static final int STATE_FAILED
public static final int STATE_PARTIALLY_FAILED
public static final int STATE_PARTIALLY_UP
public static final int STATE_PARTIALLY_DOWN
public static final int STATE_UNKNOWN
protected static org.objectweb.util.monolog.api.Logger logger
protected JmxService jmx
protected DomainMonitor dm
Constructor Detail |
---|
public BaseCluster(ClusterFactory cf)
cf
- Cluster FactoryMethod Detail |
---|
public abstract ClusterMember createClusterMember(java.lang.String svname, ServerProxy proxy)
svname
- proxy
- public javax.management.ObjectName setName(java.lang.String name) throws javax.management.JMException
name
- its name.
javax.management.JMException
- could not create MBean instancepublic java.lang.String getObjectName()
public abstract java.lang.String getType()
public boolean addMember(ClusterMember m)
m
- Member to add
public J2EEServer getServer(java.lang.String name)
name
- fo the server
public ServerProxy getServerProxy(java.lang.String name)
name
- fo the server
public java.util.Collection getServerProxyList()
public java.lang.String getState()
getState
in interface BaseClusterMBean
public java.lang.String getName()
getName
in interface BaseClusterMBean
public int getNbMembers()
getNbMembers
in interface BaseClusterMBean
public java.lang.String[] getMembers()
getMembers
in interface BaseClusterMBean
public void addServer(java.lang.String name, java.lang.String[] urls, java.lang.String clusterd) throws javax.management.JMException
addServer(String, String[], String, String, String)
addServer(String, String[], String, String, String)
(name, urls, clusterd, null, null)
addServer
in interface BaseClusterMBean
name
- logical name of the serverurls
- array of urls for connectionclusterd
- possible clusterdaemon managing the server
javax.management.JMException
public void addServer(java.lang.String svname, java.lang.String[] urls, java.lang.String cdn, java.lang.String username, java.lang.String password) throws javax.management.JMException
addServer
in interface BaseClusterMBean
svname
- logical name of the serverurls
- array of urls for connectioncdn
- clusterDaemon used to manage te serverusername
- user name to use when connecting if any. Null otherwise.password
- password to use when connecting if any. Null otherwise.
javax.management.JMException
public void removeServer(java.lang.String svname)
removeServer
in interface BaseClusterMBean
svname
- logical name of the serverpublic void startit() throws javax.management.JMException
startit
in interface BaseClusterMBean
javax.management.JMException
public void stopit() throws javax.management.JMException
stopit
in interface BaseClusterMBean
javax.management.JMException
public void deployModule(java.lang.String file)
deployModule
in interface BaseClusterMBean
file
- file to upload. One among .war,.jar,.ear,.rarpublic void undeployModule(java.lang.String file)
undeployModule
in interface BaseClusterMBean
file
- file to upload. One among .war,.jar,.ear,.rarpublic void uploadFile(java.lang.String file, boolean repl)
uploadFile
in interface BaseClusterMBean
file
- file to upload. One among .war,.jar,.ear,.rarrepl
- true if the uploaded file can replace a file with the same name in the jars directorypublic void uploadDeployModule(java.lang.String file, boolean repl)
uploadDeployModule
in interface BaseClusterMBean
file
- file to upload. One among .war,.jar,.ear,.rarrepl
- true if the uploaded file can replace a file with the same name in the jars directory
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |