|
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.
1.8.11