public class WkaBasedMembershipScheme extends Object implements MembershipScheme
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
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
|
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)
public void init() throws ClusteringFault
init
in interface MembershipScheme
ClusteringFault
- If an error occurs while configuring this schemeprotected int getLocalPort(ServerSocket socket, String hostname, int preferredPort, int portstart, int retries) throws IOException
IOException
public void joinGroup() throws ClusteringFault
joinGroup
in interface MembershipScheme
ClusteringFault
- If an error occurs while joining the grouppublic void processJoin(org.apache.catalina.tribes.Member member)
member
- The member who just joinedCopyright © 2004-2015 The Apache Software Foundation. All Rights Reserved.