org.apache.reef.wake.remote.impl

Class DefaultTransportEStage

java.lang.Object

org.apache.reef.wake.remote.impl.DefaultTransportEStage

All Implemented Interfaces:

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

public class DefaultTransportEStage
extends Object
implements EStage<TransportEvent>

A default event-based message transporting stage for both client and server.

Constructor Summary

Constructors

Constructor and Description
DefaultTransportEStage()

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

DefaultTransportEStage

@Inject
public DefaultTransportEStage()

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