Class StaticMembershipProvider
- java.lang.Object
-
- org.apache.catalina.tribes.membership.MembershipProviderBase
-
- org.apache.catalina.tribes.membership.StaticMembershipProvider
-
- All Implemented Interfaces:
ChannelListener
,RpcCallback
,Heartbeat
,MembershipProvider
public class StaticMembershipProvider extends MembershipProviderBase implements RpcCallback, ChannelListener, Heartbeat
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
StaticMembershipProvider.MemberMessage
protected class
StaticMembershipProvider.PingThread
-
Field Summary
Fields Modifier and Type Field Description protected Channel
channel
protected int
connectTimeout
protected long
expirationTime
protected long
pingInterval
protected RpcChannel
rpcChannel
protected long
rpcTimeout
protected boolean
running
protected int
sendOptions
protected static StringManager
sm
protected int
startLevel
protected java.util.ArrayList<StaticMember>
staticMembers
protected StaticMembershipProvider.PingThread
thread
protected boolean
useThread
-
Fields inherited from class org.apache.catalina.tribes.membership.MembershipProviderBase
executor, membership, membershipListener, service
-
-
Constructor Summary
Constructors Constructor Description StaticMembershipProvider()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
accept(java.io.Serializable msg, Member sender)
Invoked by the channel to determine if the listener will process this message or not.protected void
checkExpired()
void
heartbeat()
Heartbeat invocation for resources cleanup etcvoid
init(java.util.Properties properties)
void
leftOver(java.io.Serializable msg, Member sender)
If the reply has already been sent to the requesting thread, the rpc callback can handle any data that comes in after the fact.protected void
memberAdded(Member member)
protected void
memberAlive(Member member)
protected void
memberDisappeared(Member member)
void
messageReceived(java.io.Serializable msg, Member sender)
Receive a message from the channelprotected void
ping()
java.io.Serializable
replyRequest(java.io.Serializable msg, Member sender)
Allows sending a response to a received message.void
setChannel(Channel channel)
void
setStaticMembers(java.util.ArrayList<StaticMember> staticMembers)
protected Member
setupMember(Member mbr)
void
start(int level)
protected void
startMembership(Member[] members)
boolean
stop(int level)
protected void
stopMembership(Member[] members)
-
Methods inherited from class org.apache.catalina.tribes.membership.MembershipProviderBase
getMember, getMembers, hasMembers, setMembershipListener, setMembershipService
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.catalina.tribes.ChannelListener
equals, hashCode
-
-
-
-
Field Detail
-
sm
protected static final StringManager sm
-
channel
protected Channel channel
-
rpcChannel
protected RpcChannel rpcChannel
-
staticMembers
protected java.util.ArrayList<StaticMember> staticMembers
-
sendOptions
protected int sendOptions
-
expirationTime
protected long expirationTime
-
connectTimeout
protected int connectTimeout
-
rpcTimeout
protected long rpcTimeout
-
startLevel
protected int startLevel
-
useThread
protected boolean useThread
-
pingInterval
protected long pingInterval
-
running
protected volatile boolean running
-
thread
protected StaticMembershipProvider.PingThread thread
-
-
Method Detail
-
init
public void init(java.util.Properties properties) throws java.lang.Exception
- Specified by:
init
in interfaceMembershipProvider
- Overrides:
init
in classMembershipProviderBase
- Throws:
java.lang.Exception
-
start
public void start(int level) throws java.lang.Exception
- Specified by:
start
in interfaceMembershipProvider
- Throws:
java.lang.Exception
-
stop
public boolean stop(int level) throws java.lang.Exception
- Specified by:
stop
in interfaceMembershipProvider
- Throws:
java.lang.Exception
-
startMembership
protected void startMembership(Member[] members) throws ChannelException
- Throws:
ChannelException
-
memberAdded
protected void memberAdded(Member member)
-
memberDisappeared
protected void memberDisappeared(Member member)
-
memberAlive
protected void memberAlive(Member member)
-
stopMembership
protected void stopMembership(Member[] members)
-
messageReceived
public void messageReceived(java.io.Serializable msg, Member sender)
Description copied from interface:ChannelListener
Receive a message from the channel- Specified by:
messageReceived
in interfaceChannelListener
- Parameters:
msg
- Serializablesender
- - the source of the message
-
accept
public boolean accept(java.io.Serializable msg, Member sender)
Description copied from interface:ChannelListener
Invoked by the channel to determine if the listener will process this message or not.- Specified by:
accept
in interfaceChannelListener
- Parameters:
msg
- Serializablesender
- Member- Returns:
- boolean
-
replyRequest
public java.io.Serializable replyRequest(java.io.Serializable msg, Member sender)
Description copied from interface:RpcCallback
Allows sending a response to a received message.- Specified by:
replyRequest
in interfaceRpcCallback
- Parameters:
msg
- The messagesender
- Member- Returns:
- Serializable object,
null
if no reply should be sent
-
leftOver
public void leftOver(java.io.Serializable msg, Member sender)
Description copied from interface:RpcCallback
If the reply has already been sent to the requesting thread, the rpc callback can handle any data that comes in after the fact.- Specified by:
leftOver
in interfaceRpcCallback
- Parameters:
msg
- The messagesender
- Member
-
heartbeat
public void heartbeat()
Description copied from interface:Heartbeat
Heartbeat invocation for resources cleanup etc
-
ping
protected void ping() throws ChannelException
- Throws:
ChannelException
-
checkExpired
protected void checkExpired()
-
setChannel
public void setChannel(Channel channel)
-
setStaticMembers
public void setStaticMembers(java.util.ArrayList<StaticMember> staticMembers)
-
-