public class HazelcastClusteringAgent extends ParameterAdapter implements org.apache.axis2.clustering.ClusteringAgent
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_SUB_DOMAIN |
parameters
Constructor and Description |
---|
HazelcastClusteringAgent() |
Modifier and Type | Method and Description |
---|---|
void |
addGroupManagementAgent(org.apache.axis2.clustering.management.GroupManagementAgent agent,
String applicationDomain) |
void |
addGroupManagementAgent(org.apache.axis2.clustering.management.GroupManagementAgent agent,
String applicationDomain,
String applicationSubDomain) |
void |
addGroupManagementAgent(org.apache.axis2.clustering.management.GroupManagementAgent groupManagementAgent,
String applicationDomain,
String applicationSubDomain,
int groupMgtPort) |
int |
getAliveMemberCount() |
Set<String> |
getDomains() |
org.apache.axis2.clustering.management.GroupManagementAgent |
getGroupManagementAgent(String applicationDomain) |
org.apache.axis2.clustering.management.GroupManagementAgent |
getGroupManagementAgent(String applicationDomain,
String applicationSubDomain) |
List<org.apache.axis2.clustering.Member> |
getMembers() |
org.apache.axis2.clustering.management.NodeManager |
getNodeManager()
Deprecated.
|
com.hazelcast.config.Config |
getPrimaryHazelcastConfig() |
org.apache.axis2.clustering.state.StateManager |
getStateManager() |
void |
init() |
boolean |
isCoordinator() |
void |
resetGroupManagementAgent(String applicationDomain,
String applicationSubDomain) |
List<org.apache.axis2.clustering.ClusteringCommand> |
sendMessage(org.apache.axis2.clustering.ClusteringMessage clusteringMessage,
boolean isSync) |
void |
setConfigurationContext(org.apache.axis2.context.ConfigurationContext configurationContext) |
void |
setMembers(List<org.apache.axis2.clustering.Member> wkaMembers) |
void |
setNodeManager(org.apache.axis2.clustering.management.NodeManager nodeManager)
Deprecated.
|
void |
setStateManager(org.apache.axis2.clustering.state.StateManager stateManager) |
void |
shutdown() |
void |
stop() |
addParameter, deserializeParameters, getParameter, getParameters, isParameterLocked, removeParameter
public static final String DEFAULT_SUB_DOMAIN
public void init() throws org.apache.axis2.clustering.ClusteringFault
init
in interface org.apache.axis2.clustering.ClusteringAgent
org.apache.axis2.clustering.ClusteringFault
public void stop()
stop
in interface org.apache.axis2.clustering.ClusteringAgent
public org.apache.axis2.clustering.state.StateManager getStateManager()
getStateManager
in interface org.apache.axis2.clustering.ClusteringAgent
@Deprecated public org.apache.axis2.clustering.management.NodeManager getNodeManager()
getNodeManager
in interface org.apache.axis2.clustering.ClusteringAgent
public com.hazelcast.config.Config getPrimaryHazelcastConfig()
public void setStateManager(org.apache.axis2.clustering.state.StateManager stateManager)
setStateManager
in interface org.apache.axis2.clustering.ClusteringAgent
@Deprecated public void setNodeManager(org.apache.axis2.clustering.management.NodeManager nodeManager)
setNodeManager
in interface org.apache.axis2.clustering.ClusteringAgent
public void shutdown() throws org.apache.axis2.clustering.ClusteringFault
shutdown
in interface org.apache.axis2.clustering.ClusteringAgent
org.apache.axis2.clustering.ClusteringFault
public void setConfigurationContext(org.apache.axis2.context.ConfigurationContext configurationContext)
setConfigurationContext
in interface org.apache.axis2.clustering.ClusteringAgent
public void setMembers(List<org.apache.axis2.clustering.Member> wkaMembers)
setMembers
in interface org.apache.axis2.clustering.ClusteringAgent
public List<org.apache.axis2.clustering.Member> getMembers()
getMembers
in interface org.apache.axis2.clustering.ClusteringAgent
public int getAliveMemberCount()
getAliveMemberCount
in interface org.apache.axis2.clustering.ClusteringAgent
public void addGroupManagementAgent(org.apache.axis2.clustering.management.GroupManagementAgent agent, String applicationDomain)
addGroupManagementAgent
in interface org.apache.axis2.clustering.ClusteringAgent
public void addGroupManagementAgent(org.apache.axis2.clustering.management.GroupManagementAgent groupManagementAgent, String applicationDomain, String applicationSubDomain, int groupMgtPort)
addGroupManagementAgent
in interface org.apache.axis2.clustering.ClusteringAgent
public void resetGroupManagementAgent(String applicationDomain, String applicationSubDomain)
resetGroupManagementAgent
in interface org.apache.axis2.clustering.ClusteringAgent
public void addGroupManagementAgent(org.apache.axis2.clustering.management.GroupManagementAgent agent, String applicationDomain, String applicationSubDomain)
public org.apache.axis2.clustering.management.GroupManagementAgent getGroupManagementAgent(String applicationDomain)
getGroupManagementAgent
in interface org.apache.axis2.clustering.ClusteringAgent
public org.apache.axis2.clustering.management.GroupManagementAgent getGroupManagementAgent(String applicationDomain, String applicationSubDomain)
getGroupManagementAgent
in interface org.apache.axis2.clustering.ClusteringAgent
public Set<String> getDomains()
getDomains
in interface org.apache.axis2.clustering.ClusteringAgent
public boolean isCoordinator()
isCoordinator
in interface org.apache.axis2.clustering.ClusteringAgent
public List<org.apache.axis2.clustering.ClusteringCommand> sendMessage(org.apache.axis2.clustering.ClusteringMessage clusteringMessage, boolean isSync) throws org.apache.axis2.clustering.ClusteringFault
sendMessage
in interface org.apache.axis2.clustering.ClusteringAgent
org.apache.axis2.clustering.ClusteringFault
Copyright © 2016 WSO2 Inc. All rights reserved.