org.apache.reef.io.network.group.impl.operators

Class BroadcastReceiver<T>

java.lang.Object

org.apache.reef.io.network.group.impl.operators.BroadcastReceiver<T>

All Implemented Interfaces:

Broadcast.Receiver<T>, GroupCommOperator, EventHandler<GroupCommunicationMessage>

public class BroadcastReceiver<T>
extends Object
implements Broadcast.Receiver<T>, EventHandler<GroupCommunicationMessage>

Constructor Summary

Constructors

Constructor and Description
BroadcastReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)

Method Summary

Methods

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.
T	receive() Receiver the element broadcasted by sender.
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BroadcastReceiver

@Inject
public BroadcastReceiver(String groupName,
                        String operName,
                        String selfId,
                        Codec<T> dataCodec,
                        String driverId,
                        int version,
                        CommGroupNetworkHandler commGroupNetworkHandler,
                        NetworkService<GroupCommunicationMessage> netService,
                        CommunicationGroupServiceClient commGroupClient)

Method Detail

getVersion

public int getVersion()

Specified by:

getVersion in interface GroupCommOperator

initialize

public void initialize()
                throws ParentDeadException

Specified by:

initialize in interface GroupCommOperator

Throws:

ParentDeadException

getOperName

public Class<? extends Name<String>> getOperName()

Specified by:

getOperName in interface GroupCommOperator

getGroupName

public Class<? extends Name<String>> getGroupName()

Specified by:

getGroupName in interface GroupCommOperator

toString

public String toString()

Overrides:

toString in class Object

onNext

public void onNext(GroupCommunicationMessage msg)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<GroupCommunicationMessage>

Parameters:

msg - an event

receive

public T receive()
          throws NetworkException,
                 InterruptedException

Description copied from interface: Broadcast.Receiver

Receiver the element broadcasted by sender.

Specified by:

receive in interface Broadcast.Receiver<T>

Returns:

the element broadcasted by sender

Throws:

NetworkException

InterruptedException