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 ClassesModifier and TypeClassDescriptionstatic class
protected class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected Channel
protected int
protected long
protected long
protected RpcChannel
protected long
protected boolean
protected int
protected static final StringManager
protected int
protected ArrayList
<StaticMember> protected StaticMembershipProvider.PingThread
protected boolean
Fields inherited from class org.apache.catalina.tribes.membership.MembershipProviderBase
executor, membership, membershipListener, service
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
accept
(Serializable msg, Member sender) Invoked by the channel to determine if the listener will process this message or not.protected void
void
Heartbeat invocation for resources cleanup etcvoid
init
(Properties properties) void
leftOver
(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
(Serializable msg, Member sender) Receive a message from the channelprotected void
ping()
replyRequest
(Serializable msg, Member sender) Allows sending a response to a received message.void
setChannel
(Channel channel) void
setStaticMembers
(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 Details
-
sm
-
channel
-
rpcChannel
-
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
-
-
Constructor Details
-
StaticMembershipProvider
public StaticMembershipProvider()
-
-
Method Details
-
init
- Specified by:
init
in interfaceMembershipProvider
- Overrides:
init
in classMembershipProviderBase
- Throws:
Exception
-
start
- Specified by:
start
in interfaceMembershipProvider
- Throws:
Exception
-
stop
- Specified by:
stop
in interfaceMembershipProvider
- Throws:
Exception
-
startMembership
- Throws:
ChannelException
-
setupMember
-
memberAdded
-
memberDisappeared
-
memberAlive
-
stopMembership
-
messageReceived
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
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
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
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
- Throws:
ChannelException
-
checkExpired
protected void checkExpired() -
setChannel
-
setStaticMembers
-