public class BroadcastSender<T> extends Object implements Broadcast.Sender<T>, EventHandler<GroupCommunicationMessage>
Constructor and Description |
---|
BroadcastSender(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient) |
Modifier and Type | Method and Description |
---|---|
Class<? extends Name<String>> |
getGroupName() |
Class<? extends Name<String>> |
getOperName() |
int |
getVersion() |
void |
initialize() |
void |
onNext(GroupCommunicationMessage msg)
Handles an event.
|
void |
send(T element)
Send element to all receivers.
|
String |
toString() |
@Inject public BroadcastSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
public int getVersion()
getVersion
in interface GroupCommOperator
public void initialize() throws ParentDeadException
initialize
in interface GroupCommOperator
ParentDeadException
public Class<? extends Name<String>> getOperName()
getOperName
in interface GroupCommOperator
public Class<? extends Name<String>> getGroupName()
getGroupName
in interface GroupCommOperator
public void onNext(GroupCommunicationMessage msg)
EventHandler
onNext
in interface EventHandler<GroupCommunicationMessage>
msg
- an eventpublic void send(T element) throws NetworkException, InterruptedException
Broadcast.Sender
send
in interface Broadcast.Sender<T>
NetworkException
InterruptedException
Copyright © 2017 The Apache Software Foundation. All rights reserved.