org.apache.reef.wake.remote.impl

Class RemoteSenderStage

java.lang.Object

org.apache.reef.wake.remote.impl.RemoteSenderStage

All Implemented Interfaces:

AutoCloseable, Stage

public class RemoteSenderStage
extends Object
implements Stage

Stage to manage resources related to sending event remotely.

Constructor Summary

Constructors

Constructor and Description
RemoteSenderStage(Encoder encoder, Transport transport, int numThreads) Constructs a remote sender stage.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the stage.
<T> EventHandler<RemoteEvent<T>>	getHandler() Returns a new remote sender event handler.

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteSenderStage

public RemoteSenderStage(Encoder encoder,
                 Transport transport,
                 int numThreads)

Constructs a remote sender stage.

Parameters:

encoder - the encoder of the event

transport - the transport to send events

numThreads - the number of threads

Method Detail

getHandler

public <T> EventHandler<RemoteEvent<T>> getHandler()

Returns a new remote sender event handler.

Returns:

a remote sender event handler

close

public void close()
           throws Exception

Closes the stage.

Specified by:

close in interface AutoCloseable

Throws:

Exception