org.apache.catalina.tribes.membership
public class McastService extends Object implements MembershipService, MembershipListener
Version: $Revision: 892864 $, $Date: 2009-12-21 17:26:07 +0100 (Mon, 21 Dec 2009) $
Field Summary | |
---|---|
protected byte[] | domain |
protected static Member[] | EMPTY_MEMBERS
Return all the members |
protected McastServiceImpl | impl
A handle to the actual low level implementation |
protected MembershipListener | listener
A membership listener delegate (should be the cluster :) |
protected MemberImpl | localMember
The local member |
protected byte[] | payload |
protected Properties | properties
The implementation specific properties |
protected StringManager | sm
The string manager for this package. |
Constructor Summary | |
---|---|
McastService()
Create a membership service. |
Method Summary | |
---|---|
Member | findMemberByName(String name)
Return the member by name |
String | getAddress() |
String | getBind() |
byte[] | getDomain() |
long | getDropTime() |
long | getFrequency() |
String | getInfo()
Return descriptive information about this implementation and the
corresponding version number, in the format
<description>/<version> . |
Member | getLocalMember(boolean alive)
Return the local member |
String | getLocalMemberName()
Return the local member name |
String | getMcastAddr() |
String | getMcastBindAddress() |
long | getMcastDropTime() |
long | getMcastFrequency() |
int | getMcastPort() |
int | getMcastSoTimeout() |
int | getMcastTTL() |
Member | getMember(Member mbr) |
Member[] | getMembers() |
String[] | getMembersByName()
Return all the members by name |
byte[] | getPayload() |
int | getPort() |
Properties | getProperties()
Return the properties, see setProperties |
int | getSoTimeout() |
int | getTtl() |
boolean | hasMembers()
has members? |
protected void | hasProperty(Properties properties, String name)
Check if a required property is available. |
static void | main(String[] args)
Simple test program |
void | memberAdded(Member member) |
void | memberDisappeared(Member member)
Callback from the impl when a new member has been received |
void | removeMembershipListener()
Remove the membership listener |
void | setAddress(String addr) |
void | setBind(String bindaddr) |
void | setDomain(byte[] domain) |
void | setDomain(String domain) |
void | setDropTime(long time) |
void | setFrequency(long time) |
void | setLocalMemberProperties(String listenHost, int listenPort)
Sets the local member properties for broadcasting |
void | setMcastAddr(String addr) |
void | setMcastBindAddress(String bindaddr) |
void | setMcastDropTime(long time) |
void | setMcastFrequency(long time) |
void | setMcastPort(int port) |
void | setMcastSoTimeout(int mcastSoTimeout) |
void | setMcastTTL(int mcastTTL) |
void | setMembershipListener(MembershipListener listener)
Add a membership listener, this version only supports one listener per service,
so calling this method twice will result in only the second listener being active. |
void | setPayload(byte[] payload) |
void | setPort(int port) |
void | setProperties(Properties properties) |
void | setRecoveryCounter(int recoveryCounter) |
void | setRecoveryEnabled(boolean recoveryEnabled) |
void | setRecoverySleepTime(long recoverySleepTime) |
void | setSoTimeout(int mcastSoTimeout) |
void | setTtl(int mcastTTL) |
void | start()
Start broadcasting and listening to membership pings |
void | start(int level) |
void | stop(int svc)
Stop broadcasting and listening to membership pings |
<description>/<version>
.Deprecated: use getAddress
Returns: String
Deprecated: use getBind
Returns: String
Deprecated: use getDropTime
Returns: long
Deprecated: use getFrequency
Returns: long
Deprecated: use getPort()
Returns: int
Deprecated: use getSoTimeout
Returns: int
Deprecated: use getTtl
Returns: int
Parameters: properties The set of properties name The property to check for
Parameters: args Command-line arguments
Throws: Exception If an error occurs
Parameters: member The member
Deprecated: use setAddress
Parameters: addr String
Deprecated: use setFrequency
Parameters: time long
Deprecated: use setPort
Parameters: port int
Deprecated: use setSoTimeout
Parameters: mcastSoTimeout int
Deprecated: use setTtl
Parameters: mcastTTL int
Parameters: listener The listener
Parameters: properties
All are required
1. mcastPort - the port to listen to
2. mcastAddress - the mcast group address
4. bindAddress - the bind address if any - only one that can be null
5. memberDropTime - the time a member is gone before it is considered gone.
6. mcastFrequency - the frequency of sending messages
7. tcpListenPort - the port this member listens to
8. tcpListenHost - the bind address of this member
Throws: java.lang.IllegalArgumentException if a property is missing.
Throws: java.lang.Exception if a IO error occurs