Methods Summary |
---|
public void | callAsynchMethodOnCluster(java.lang.String serviceName, java.lang.String methodName, java.lang.Object[] args, boolean excludeSelf)
|
public void | callAsynchMethodOnCluster(java.lang.String serviceName, java.lang.String methodName, java.lang.Object[] args, java.lang.Class[] types, boolean excludeSelf)Invoke a asynchronous RPC call on all nodes of the partition/cluster. The
call will return immediately and will not wait that the nodes answer. Thus
no answer is available.
|
public java.util.ArrayList | callMethodOnCluster(java.lang.String serviceName, java.lang.String methodName, java.lang.Object[] args, java.lang.Class[] types, boolean excludeSelf)Invoke a synchronous RPC call on all nodes of the partition/cluster
|
public java.util.ArrayList | callMethodOnCluster(java.lang.String serviceName, java.lang.String methodName, java.lang.Object[] args, boolean excludeSelf)
|
public java.util.ArrayList | callMethodOnCoordinatorNode(java.lang.String serviceName, java.lang.String methodName, java.lang.Object[] args, java.lang.Class[] types, boolean excludeSelf)Calls method on Cluster coordinator node only. The cluster coordinator node is the first node to join the
cluster or the first node in the current cluster view.
|
public boolean | getAllowSynchronousMembershipNotifications()Returns whether this partition will synchronously notify any
HAMembershipListeners of membership changes using the calling thread
from the underlying ClusterPartition .
|
public ClusterNode | getClusterNode()Return member node for the current cluster node.
|
public ClusterNode[] | getClusterNodes()Return the member nodes that built the current view i.e. the current partition.
|
public java.util.Vector | getCurrentView()Return the list of member nodes that built the current view i.e. the current partition.
|
public long | getCurrentViewId()Each time the partition topology changes, a new view is computed. A view is a list of members,
the first member being the coordinator of the view. Each view also has a distinct identifier.
|
public DistributedReplicantManager | getDistributedReplicantManager()Accessor to the DRM that is linked to this partition.
|
public DistributedState | getDistributedStateService()Accessor the the DistributedState (DS) that is linked to this partition.
|
public java.lang.String | getNodeName()Return the name of this node in the current partition. The name is
dynamically determined by the partition. The name will be the String
returned by getClusterNode().getName() .
|
public java.lang.String | getPartitionName()The name of the partition. Either set when creating the partition
(MBEAN definition) or uses the default name
|
public void | registerMembershipListener(org.jboss.ha.framework.interfaces.HAPartition$HAMembershipListener listener)Subscribes to receive {@link HAMembershipListener} events.
|
public void | registerRPCHandler(java.lang.String serviceName, java.lang.Object handler)The partition receives RPC calls from other nodes in the cluster and demultiplex
them, according to a service name, to a particular service. Consequently, each
service must first subscribe with a particular service name in the partition. The subscriber
does not need to implement any specific interface: the call is handled
dynamically through reflection.
|
public void | setAllowSynchronousMembershipNotifications(boolean allowSync)Sets whether this partition will synchronously notify any
HAMembershipListeners of membership changes using the calling thread
from the underlying ClusterPartition .
|
public void | subscribeToStateTransferEvents(java.lang.String serviceName, org.jboss.ha.framework.interfaces.HAPartition$HAPartitionStateTransfer subscriber)Register a service that will participate in state transfer protocol and receive callbacks
|
public void | unregisterMembershipListener(org.jboss.ha.framework.interfaces.HAPartition$HAMembershipListener listener)Unsubscribes from receiving {@link HAMembershipListener} events.
|
public void | unregisterRPCHandler(java.lang.String serviceName, java.lang.Object subscriber)Unregister the service from the partition
|
public void | unsubscribeFromStateTransferEvents(java.lang.String serviceName, org.jboss.ha.framework.interfaces.HAPartition$HAPartitionStateTransfer subscriber)Unregister a service from state transfer callbacks.
|