Server to handle incoming remote messages. More...

Inherits IDisposable.

Public Member Functions
	TransportServer (IPEndPoint localEndpoint, IObserver< TransportEvent< T >> remoteHandler, ICodec< T > codec, ITcpPortProvider tcpPortProvider)
	Constructs a TransportServer to listen for remote events. More...

void	Run ()
	Starts listening for incoming remote messages. More...

void	Dispose ()
	Close the TransportServer and all open connections More...

void	Dispose (bool disposing)

Properties
IPEndPoint	LocalEndpoint `[get]`
	Returns the listening endpoint for the TransportServer More...

Detailed Description

Server to handle incoming remote messages.

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.Remote.Impl.TransportServer< T >.TransportServer	(	IPEndPoint	localEndpoint,
		IObserver< TransportEvent< T >>	remoteHandler,
		ICodec< T >	codec,
		ITcpPortProvider	tcpPortProvider
	)

inline

Constructs a TransportServer to listen for remote events.

Listens on the specified remote endpoint. When it receives a remote event, it will invoke the specified remote handler.

Parameters

localEndpoint	Endpoint to listen on
remoteHandler	The handler to invoke when receiving incoming remote messages
codec	The codec to encode/decode
tcpPortProvider	provides port numbers to listen

void Org.Apache.REEF.Wake.Remote.Impl.TransportServer< T >.Dispose ( )

inline

Close the TransportServer and all open connections

void Org.Apache.REEF.Wake.Remote.Impl.TransportServer< T >.Dispose ( bool disposing )

inline

void Org.Apache.REEF.Wake.Remote.Impl.TransportServer< T >.Run ( )

inline

Starts listening for incoming remote messages.

get

Returns the listening endpoint for the TransportServer

The documentation for this class was generated from the following file: