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

Class CtrlMsgSender

java.lang.Object

org.apache.reef.io.network.group.impl.driver.CtrlMsgSender

All Implemented Interfaces:

EventHandler<GroupCommunicationMessage>

public class CtrlMsgSender
extends Object
implements EventHandler<GroupCommunicationMessage>

Event handler that receives ctrl msgs and. dispatched them using network service

Constructor Summary

Constructors

Constructor and Description
CtrlMsgSender(IdentifierFactory idFac, NetworkService<GroupCommunicationMessage> netService)

Method Summary

Modifier and Type	Method and Description
void	onNext(GroupCommunicationMessage srcCtrlMsg) Handles an event.

Methods inherited from class java.lang.Object

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

Constructor Detail

CtrlMsgSender

public CtrlMsgSender(IdentifierFactory idFac,
                     NetworkService<GroupCommunicationMessage> netService)

Method Detail

onNext

public void onNext(GroupCommunicationMessage srcCtrlMsg)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<GroupCommunicationMessage>

Parameters:

srcCtrlMsg - an event