This project has retired. For details please refer to its Attic page.
Apache REEF: Org.Apache.REEF.Wake.Remote.Impl.TransportClient< T > Class Template Reference
Apache REEF  0.15.0
Retainable Evaluator Execution Framework
Public Member Functions | Protected Member Functions | Properties | List of all members
Org.Apache.REEF.Wake.Remote.Impl.TransportClient< T > Class Template Reference

Establish connections to TransportServer for remote message passing More...

Inherits IDisposable.

Public Member Functions

 TransportClient (IPEndPoint remoteEndpoint, ICodec< T > codec, ITcpClientConnectionFactory clientFactory)
 Construct a TransportClient. More...
 
 TransportClient (IPEndPoint remoteEndpoint, ICodec< T > codec, IObserver< TransportEvent< T >> observer, ITcpClientConnectionFactory clientFactory)
 Construct a TransportClient. More...
 
void Send (T message)
 Send the remote message. More...
 
void Dispose ()
 Close all opened connections More...
 

Protected Member Functions

void Dispose (bool disposing)
 

Properties

ILink< T > Link [get]
 Gets the underlying transport link. More...
 

Detailed Description

Establish connections to TransportServer for remote message passing

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.Remote.Impl.TransportClient< T >.TransportClient ( IPEndPoint  remoteEndpoint,
ICodec< T >  codec,
ITcpClientConnectionFactory  clientFactory 
)
inline

Construct a TransportClient.

Used to send messages to the specified remote endpoint.

Parameters
remoteEndpointThe endpoint of the remote server to connect to
codecCodec to decode/encode
clientFactoryTcpClient factory
Org.Apache.REEF.Wake.Remote.Impl.TransportClient< T >.TransportClient ( IPEndPoint  remoteEndpoint,
ICodec< T >  codec,
IObserver< TransportEvent< T >>  observer,
ITcpClientConnectionFactory  clientFactory 
)
inline

Construct a TransportClient.

Used to send messages to the specified remote endpoint.

Parameters
remoteEndpointThe endpoint of the remote server to connect to
codecCodec to decode/encodec
observerCallback used when receiving responses from remote host
clientFactoryTcpClient factory

Member Function Documentation

Close all opened connections

void Org.Apache.REEF.Wake.Remote.Impl.TransportClient< T >.Dispose ( bool  disposing)
inlineprotected
void Org.Apache.REEF.Wake.Remote.Impl.TransportClient< T >.Send ( message)
inline

Send the remote message.

Parameters
messageThe message to send

Property Documentation

Gets the underlying transport link.


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