Modifier and Type | Method and Description |
---|---|
abstract void |
ClusteringCommand.execute(ConfigurationContext configContext) |
void |
MembershipScheme.init()
Initialize this membership scheme
|
void |
ClusteringAgent.init()
Initialize this node, and join the cluster
|
void |
MembershipScheme.joinGroup()
JOIN the group
|
List<ClusteringCommand> |
ClusteringAgent.sendMessage(ClusteringMessage msg,
boolean isRpcMessage)
Send a message to all members in this member's primary cluster
|
void |
MessageSender.sendToGroup(ClusteringCommand msg) |
void |
MessageSender.sendToSelf(ClusteringCommand msg) |
void |
ClusteringAgent.shutdown()
Disconnect this node from the cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
GetStateResponseCommand.execute(ConfigurationContext configContext) |
void |
GetStateCommand.execute(ConfigurationContext configCtx) |
void |
GetConfigurationResponseCommand.execute(ConfigurationContext configContext) |
void |
GetConfigurationCommand.execute(ConfigurationContext configCtx) |
abstract void |
ControlCommand.execute(ConfigurationContext configurationContext)
Execute this command
|
Modifier and Type | Method and Description |
---|---|
void |
MemberListCommand.execute(ConfigurationContext configurationContext) |
void |
MemberJoinedCommand.execute(ConfigurationContext configurationContext) |
void |
JoinGroupCommand.execute(ConfigurationContext configurationContext) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultNodeManager.commit() |
void |
NodeManager.commit()
Second phase of the 2-phase commit protocol.
|
void |
DefaultNodeManager.exceptionOccurred(Throwable throwable) |
void |
NodeManager.exceptionOccurred(Throwable throwable)
To notify other nodes that an Exception occurred, during the processing
of a
NodeManagementCommand |
void |
DefaultNodeManager.prepare() |
void |
NodeManager.prepare()
First phase of the 2-phase commit protocol.
|
void |
DefaultNodeManager.rollback() |
void |
NodeManager.rollback()
Rollback whatever was done
|
void |
DefaultGroupManagementAgent.send(GroupManagementCommand command) |
void |
GroupManagementAgent.send(GroupManagementCommand command)
Send a GroupManagementCommand to the group
|
protected void |
DefaultNodeManager.send(Throwable throwable) |
void |
DefaultNodeManager.sendMessage(NodeManagementCommand command) |
void |
NodeManager.sendMessage(NodeManagementCommand command)
Execute a NodeManagementCommand
|
Modifier and Type | Method and Description |
---|---|
void |
ShutdownMemberCommand.execute(ConfigurationContext configContext) |
Modifier and Type | Method and Description |
---|---|
static StateClusteringCommand |
StateClusteringCommandFactory.getUpdateCommand(AbstractContext context,
String[] propertyNames) |
void |
DefaultStateManager.removeContext(AbstractContext context) |
void |
StateManager.removeContext(AbstractContext context)
This method is called when
AbstractContext is removed from the system |
static void |
Replicator.replicate(AbstractContext abstractContext)
Replicate all serializable properties stored in the given
abstractContext . |
static void |
Replicator.replicate(AbstractContext abstractContext,
String[] propertyNames)
Replicate all the properties given in
propertyNames
in the specified abstractContext |
static void |
Replicator.replicate(MessageContext msgContext)
Replicates all serializable properties in the ConfigurationContext, ServiceGroupContext &
ServiceContext
|
void |
DefaultStateManager.replicateState(StateClusteringCommand command) |
void |
StateManager.replicateState(StateClusteringCommand command)
Replicate state using a custom StateClusteringCommand
|
static void |
Replicator.replicateState(StateClusteringCommand command,
AxisConfiguration axisConfig)
Replicate state using a custom StateClusteringCommand
|
void |
DefaultStateManager.updateContext(AbstractContext context) |
void |
StateManager.updateContext(AbstractContext context)
This method is called when properties in an
AbstractContext are updated. |
void |
DefaultStateManager.updateContext(AbstractContext context,
String[] propertyNames) |
void |
StateManager.updateContext(AbstractContext context,
String[] propertyNames)
This method is called when one need to update/replicate only certains properties in the
specified
context |
void |
DefaultStateManager.updateContexts(AbstractContext[] contexts) |
void |
StateManager.updateContexts(AbstractContext[] contexts)
This method is called when properties in a collection of
AbstractContext s are updated. |
Modifier and Type | Method and Description |
---|---|
void |
UpdateServiceStateCommand.execute(ConfigurationContext configurationContext) |
void |
UpdateServiceGroupStateCommand.execute(ConfigurationContext configContext) |
void |
UpdateConfigurationStateCommand.execute(ConfigurationContext configurationContext) |
void |
StateClusteringCommandCollection.execute(ConfigurationContext configContext) |
void |
DeleteServiceStateCommand.execute(ConfigurationContext configurationContext) |
void |
DeleteServiceGroupStateCommand.execute(ConfigurationContext configurationContext) |
Modifier and Type | Method and Description |
---|---|
void |
WkaBasedMembershipScheme.init()
Configure the membership related to the WKA based scheme
|
void |
TribesClusteringAgent.init()
Initialize the cluster.
|
void |
MulticastBasedMembershipScheme.init() |
void |
WkaBasedMembershipScheme.joinGroup()
JOIN the group and get the member list
|
void |
MulticastBasedMembershipScheme.joinGroup() |
List<ClusteringCommand> |
TribesClusteringAgent.sendMessage(ClusteringMessage message,
boolean isRpcMessage) |
void |
ChannelSender.sendToGroup(ClusteringCommand msg) |
void |
ChannelSender.sendToGroup(ClusteringCommand msg,
MembershipManager membershipManager,
int additionalOptions) |
void |
ChannelSender.sendToMember(ClusteringCommand cmd,
org.apache.catalina.tribes.Member member) |
void |
ChannelSender.sendToSelf(ClusteringCommand msg) |
void |
TribesClusteringAgent.shutdown()
Shutdown the cluster.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMessageReceiver.replicateState(MessageContext messageContext) |
Copyright © 2004-2015 The Apache Software Foundation. All Rights Reserved.