org.apache.reef.wake.remote.impl

Class OrderedRemoteReceiverStage

java.lang.Object

org.apache.reef.wake.remote.impl.OrderedRemoteReceiverStage

All Implemented Interfaces:

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

public class OrderedRemoteReceiverStage
extends Object
implements EStage<TransportEvent>

Receive incoming events and dispatch to correct handlers in order.

Constructor Summary

Constructors

Constructor and Description
OrderedRemoteReceiverStage(EventHandler<RemoteEvent<byte[]>> handler, EventHandler<Throwable> errorHandler) Constructs an ordered remote receiver stage.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	onNext(TransportEvent value) Handles an event.

Methods inherited from class java.lang.Object

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

Constructor Detail

OrderedRemoteReceiverStage

public OrderedRemoteReceiverStage(EventHandler<RemoteEvent<byte[]>> handler,
                          EventHandler<Throwable> errorHandler)

Constructs an ordered remote receiver stage.

Parameters:

handler - the handler of remote events

errorHandler - the exception handler

Method Detail

onNext

public void onNext(TransportEvent value)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<TransportEvent>

Parameters:

value - an event

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception