MembershipListener
, MembershipService
McastService
, StaticMembershipService
public abstract class MembershipServiceBase extends java.lang.Object implements MembershipService, MembershipListener
Modifier and Type | Field | Description |
---|---|---|
protected Channel |
channel |
|
protected MembershipListener |
listener |
|
protected java.util.Properties |
properties |
The implementation specific properties
|
MBR_RX, MBR_TX
Constructor | Description |
---|---|
MembershipServiceBase() |
Modifier and Type | Method | Description |
---|---|---|
void |
broadcast(ChannelMessage message) |
Broadcasts a message to all members.
|
Member |
findMemberByName(java.lang.String name) |
Get a member.
|
Channel |
getChannel() |
Return the channel that is related to this MembershipService
|
Member |
getMember(Member mbr) |
Retrieve the specified member from the membership.
|
Member[] |
getMembers() |
|
java.lang.String[] |
getMembersByName() |
|
java.util.Properties |
getProperties() |
|
boolean |
hasMembers() |
|
void |
memberAdded(Member member) |
A member was added to the group
|
void |
memberDisappeared(Member member) |
A member was removed from the group
If the member left voluntarily, the Member.getCommand will contain the Member.SHUTDOWN_PAYLOAD data |
void |
removeMembershipListener() |
Removes the membership listener.
|
void |
setChannel(Channel channel) |
Set the channel that is related to this MembershipService
|
void |
setMembershipListener(MembershipListener listener) |
Sets the membership listener, only one listener can be added.
|
void |
setProperties(java.util.Properties properties) |
Sets the properties for the membership service.
|
void |
start() |
Starts the membership service.
|
getLocalMember, getMembershipProvider, setDomain, setLocalMemberProperties, setPayload, start, stop
protected java.util.Properties properties
protected volatile MembershipListener listener
protected Channel channel
public void setProperties(java.util.Properties properties)
start()
method is called.
The properties are implementation specific.setProperties
in interface MembershipService
properties
- - to be used to configure the membership service.public java.util.Properties getProperties()
getProperties
in interface MembershipService
public boolean hasMembers()
hasMembers
in interface MembershipService
public Member getMember(Member mbr)
MembershipService
getMember
in interface MembershipService
mbr
- The member to retrievepublic Member[] getMembers()
getMembers
in interface MembershipService
public java.lang.String[] getMembersByName()
getMembersByName
in interface MembershipService
public Member findMemberByName(java.lang.String name)
MembershipService
findMemberByName
in interface MembershipService
name
- The member namepublic void setMembershipListener(MembershipListener listener)
MembershipService
setMembershipListener
in interface MembershipService
listener
- The listenerpublic void removeMembershipListener()
MembershipService
removeMembershipListener
in interface MembershipService
public void memberAdded(Member member)
MembershipListener
memberAdded
in interface MembershipListener
member
- Member - the member that was addedpublic void memberDisappeared(Member member)
MembershipListener
memberDisappeared
in interface MembershipListener
member
- MemberMember.SHUTDOWN_PAYLOAD
public void broadcast(ChannelMessage message) throws ChannelException
MembershipService
broadcast
in interface MembershipService
message
- The message to broadcastChannelException
- Message broadcast failedpublic Channel getChannel()
MembershipService
getChannel
in interface MembershipService
public void setChannel(Channel channel)
MembershipService
setChannel
in interface MembershipService
channel
- The channelpublic void start() throws java.lang.Exception
MembershipService
start
in interface MembershipService
java.lang.Exception
- if the service fails to start.Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.