Heartbeat
ReplicationTransmitter
public interface ChannelSender extends Heartbeat
ChannelSender
interface is the data sender component
at the bottom layer, the IO layer (for layers see the javadoc for the Channel
interface).Modifier and Type | Method | Description |
---|---|---|
void |
add(Member member) |
Notify the sender of a member being added to the group.
Optional. |
Channel |
getChannel() |
Return the channel that is related to this ChannelSender
|
void |
heartbeat() |
A channel heartbeat, use this method to clean up resources
|
void |
remove(Member member) |
Notification that a member has been removed or crashed.
|
void |
sendMessage(ChannelMessage message,
Member[] destination) |
Send a message to one or more recipients.
|
void |
setChannel(Channel channel) |
Set the channel that is related to this ChannelSender
|
void |
start() |
Start the channel sender
|
void |
stop() |
Stop the channel sender
|
void add(Member member)
member
- Membervoid remove(Member member)
member
- Membervoid start() throws java.io.IOException
java.io.IOException
- if preprocessing takes place and an error happensvoid stop()
void heartbeat()
void sendMessage(ChannelMessage message, Member[] destination) throws ChannelException
message
- ChannelMessage - the message to be sentdestination
- Member[] - the destinationsChannelException
- - if an error happens, the ChannelSender MUST report
individual send failures on a per member basis, using ChannelException.addFaultyMemberChannelException.addFaultyMember(Member,java.lang.Exception)
Channel getChannel()
void setChannel(Channel channel)
channel
- The channelCopyright © 2000-2018 Apache Software Foundation. All Rights Reserved.