org.apache.axis2.clustering.tribes
Class WkaBasedMembershipScheme

java.lang.Object
  org.apache.axis2.clustering.tribes.WkaBasedMembershipScheme

All Implemented Interfaces:

MembershipScheme

public class WkaBasedMembershipScheme
extends Object
implements MembershipScheme

Implementation of the WKA(well-known address) based membership scheme. In this scheme, membership is discovered using a few well-known members (who run at well-known IP addresses)

Constructor Summary

WkaBasedMembershipScheme(org.apache.catalina.tribes.ManagedChannel channel, OperationMode mode, List<MembershipManager> applicationDomainMembershipManagers, MembershipManager primaryMembershipManager, Map<String,Parameter> parameters, byte[] domain, List<Member> members, boolean atmostOnceMessageSemantics, boolean preserverMsgOrder)

Method Summary

protected int	getLocalPort(ServerSocket socket, String hostname, int preferredPort, int portstart, int retries)
Parameter	getParameter(String name)
void	init() Configure the membership related to the WKA based scheme
void	joinGroup() JOIN the group and get the member list
void	processJoin(org.apache.catalina.tribes.Member member) When a JOIN message is received from some other member, it is notified using this method, so that membership scheme specific processing can be carried out

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WkaBasedMembershipScheme

public WkaBasedMembershipScheme(org.apache.catalina.tribes.ManagedChannel channel,
                                OperationMode mode,
                                List<MembershipManager> applicationDomainMembershipManagers,
                                MembershipManager primaryMembershipManager,
                                Map<String,Parameter> parameters,
                                byte[] domain,
                                List<Member> members,
                                boolean atmostOnceMessageSemantics,
                                boolean preserverMsgOrder)

Method Detail

init

public void init()
          throws ClusteringFault

Configure the membership related to the WKA based scheme

Specified by:

init in interface MembershipScheme

Throws:

ClusteringFault - If an error occurs while configuring this scheme

getLocalPort

protected int getLocalPort(ServerSocket socket,
                           String hostname,
                           int preferredPort,
                           int portstart,
                           int retries)
                    throws IOException

Throws:

IOException

joinGroup

public void joinGroup()
               throws ClusteringFault

JOIN the group and get the member list

Specified by:

joinGroup in interface MembershipScheme

Throws:

ClusteringFault - If an error occurs while joining the group

processJoin

public void processJoin(org.apache.catalina.tribes.Member member)

When a JOIN message is received from some other member, it is notified using this method, so that membership scheme specific processing can be carried out

Parameters:

member - The member who just joined

getParameter

public Parameter getParameter(String name)