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