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

Class CommGroupNetworkHandlerImpl

java.lang.Object

org.apache.reef.io.network.group.impl.task.CommGroupNetworkHandlerImpl

All Implemented Interfaces:

CommGroupNetworkHandler, EventHandler<GroupCommunicationMessage>

public class CommGroupNetworkHandlerImpl
extends Object
implements CommGroupNetworkHandler

Constructor Summary

Constructors

Constructor and Description
CommGroupNetworkHandlerImpl()

Method Summary

Methods

Modifier and Type	Method and Description
void	addTopologyElement(Class<? extends Name<String>> operName)
void	onNext(GroupCommunicationMessage msg) Handles an event.
void	register(Class<? extends Name<String>> operName, EventHandler<GroupCommunicationMessage> operHandler)
byte[]	waitForTopologyChanges(Class<? extends Name<String>> operName)
GroupCommunicationMessage	waitForTopologyUpdate(Class<? extends Name<String>> operName)

Methods inherited from class java.lang.Object

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

Constructor Detail

CommGroupNetworkHandlerImpl

@Inject
public CommGroupNetworkHandlerImpl()

Method Detail

register

public void register(Class<? extends Name<String>> operName,
            EventHandler<GroupCommunicationMessage> operHandler)

Specified by:

register in interface CommGroupNetworkHandler

addTopologyElement

public void addTopologyElement(Class<? extends Name<String>> operName)

Specified by:

addTopologyElement in interface CommGroupNetworkHandler

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

waitForTopologyChanges

public byte[] waitForTopologyChanges(Class<? extends Name<String>> operName)

Specified by:

waitForTopologyChanges in interface CommGroupNetworkHandler

waitForTopologyUpdate

public GroupCommunicationMessage waitForTopologyUpdate(Class<? extends Name<String>> operName)

Specified by:

waitForTopologyUpdate in interface CommGroupNetworkHandler