org.apache.reef.wake.remote.impl

Class RemoteReceiverStage

java.lang.Object

org.apache.reef.wake.remote.impl.RemoteReceiverStage

All Implemented Interfaces:

AutoCloseable, EStage<TransportEvent>, EventHandler<TransportEvent>, Stage

public class RemoteReceiverStage
extends Object
implements EStage<TransportEvent>

Receive incoming events and dispatch to correct handlers

Constructor Summary

Constructors

Constructor and Description
RemoteReceiverStage(EventHandler<RemoteEvent<byte[]>> handler, EventHandler<Throwable> errorHandler, int numThreads) Constructs a remote receiver stage

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the stage
void	onNext(TransportEvent value) Handles the received event

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteReceiverStage

public RemoteReceiverStage(EventHandler<RemoteEvent<byte[]>> handler,
                   EventHandler<Throwable> errorHandler,
                   int numThreads)

Constructs a remote receiver stage

Parameters:

handler - the handler of remote events

errorHandler - the exception handler

numThreads - the number of threads

Method Detail

onNext

public void onNext(TransportEvent value)

Handles the received event

Specified by:

onNext in interface EventHandler<TransportEvent>

Parameters:

value - the event

close

public void close()
           throws Exception

Closes the stage

Specified by:

close in interface AutoCloseable

Throws:

Exception