Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
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... | |
Establish connections to TransportServer for remote message passing
|
inline |
Construct a TransportClient.
Used to send messages to the specified remote endpoint.
remoteEndpoint | The endpoint of the remote server to connect to |
codec | Codec to decode/encode |
clientFactory | TcpClient factory |
|
inline |
Construct a TransportClient.
Used to send messages to the specified remote endpoint.
remoteEndpoint | The endpoint of the remote server to connect to |
codec | Codec to decode/encodec |
observer | Callback used when receiving responses from remote host |
clientFactory | TcpClient factory |
|
inline |
Close all opened connections
|
inlineprotected |
|
inline |
Send the remote message.
message | The message to send |
Gets the underlying transport link.