public class StaticMembershipService extends MembershipServiceBase implements StaticMembershipServiceMBean
Modifier and Type | Field and Description |
---|---|
protected static StringManager |
sm |
protected ArrayList<StaticMember> |
staticMembers |
channel, listener, properties
MBR_RX, MBR_TX
Constructor and Description |
---|
StaticMembershipService() |
Modifier and Type | Method and Description |
---|---|
void |
addStaticMember(StaticMember member) |
protected StaticMembershipProvider |
buildMembershipProvider() |
int |
getConnectTimeout() |
long |
getExpirationTime() |
Member |
getLocalMember(boolean incAliveTime)
Get the local member.
|
MembershipProvider |
getMembershipProvider()
Get the MembershipProvider
|
long |
getPingInterval() |
long |
getRpcTimeout() |
ArrayList<StaticMember> |
getStaticMembers() |
boolean |
getUseThread() |
void |
removeStaticMember(StaticMember member) |
void |
setConnectTimeout(int connectTimeout) |
protected void |
setDefaults(Properties properties) |
void |
setDomain(byte[] domain) |
void |
setExpirationTime(long expirationTime) |
void |
setLocalMember(StaticMember member) |
void |
setLocalMemberProperties(String listenHost,
int listenPort,
int securePort,
int udpPort)
Sets the local member properties for broadcasting.
|
void |
setPayload(byte[] payload)
Set a payload to be broadcasted with each membership
broadcast.
|
void |
setPingInterval(long pingInterval) |
void |
setProperties(Properties properties)
Sets the properties for the membership service.
|
void |
setRpcTimeout(long rpcTimeout) |
void |
setUseThread(boolean useThread) |
void |
start(int level)
Starts the membership service.
|
void |
stop(int level)
Starts the membership service.
|
broadcast, findMemberByName, getChannel, getMember, getMembers, getMembersByName, getProperties, hasMembers, memberAdded, memberDisappeared, removeMembershipListener, setChannel, setMembershipListener, start
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
findMemberByName, getMembersByName, getProperties, hasMembers
protected static final StringManager sm
protected final ArrayList<StaticMember> staticMembers
public void start(int level) throws Exception
MembershipService
start
in interface MembershipService
level
- - level MBR_RX starts listening for members, level MBR_TX
starts broad casting the serverException
- if the service fails to start.IllegalArgumentException
- if the level is incorrect.protected StaticMembershipProvider buildMembershipProvider() throws Exception
Exception
public void stop(int level)
MembershipService
stop
in interface MembershipService
level
- - level MBR_RX stops listening for members, level MBR_TX
stops broad casting the serverpublic Member getLocalMember(boolean incAliveTime)
MembershipService
getLocalMember
in interface MembershipService
incAliveTime
- true
to set the alive time
on the local memberpublic void setLocalMemberProperties(String listenHost, int listenPort, int securePort, int udpPort)
MembershipService
setLocalMemberProperties
in interface MembershipService
listenHost
- Listen to hostlistenPort
- Listen to portsecurePort
- Use a secure portudpPort
- Use UDPpublic void setPayload(byte[] payload)
MembershipService
setPayload
in interface MembershipService
payload
- byte[]public void setDomain(byte[] domain)
setDomain
in interface MembershipService
public MembershipProvider getMembershipProvider()
MembershipService
getMembershipProvider
in interface MembershipService
public ArrayList<StaticMember> getStaticMembers()
public void addStaticMember(StaticMember member)
public void removeStaticMember(StaticMember member)
public void setLocalMember(StaticMember member)
public long getExpirationTime()
getExpirationTime
in interface StaticMembershipServiceMBean
public void setExpirationTime(long expirationTime)
public int getConnectTimeout()
getConnectTimeout
in interface StaticMembershipServiceMBean
public void setConnectTimeout(int connectTimeout)
public long getRpcTimeout()
getRpcTimeout
in interface StaticMembershipServiceMBean
public void setRpcTimeout(long rpcTimeout)
public boolean getUseThread()
getUseThread
in interface StaticMembershipServiceMBean
public void setUseThread(boolean useThread)
public long getPingInterval()
getPingInterval
in interface StaticMembershipServiceMBean
public void setPingInterval(long pingInterval)
public void setProperties(Properties properties)
MembershipServiceBase
start()
method is called.
The properties are implementation specific.setProperties
in interface MembershipService
setProperties
in class MembershipServiceBase
properties
- - to be used to configure the membership service.protected void setDefaults(Properties properties)
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.