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 and Description |
---|---|
void |
add(Member member)
Notify the sender of a member being added to the group.
|
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 |
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)
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.