public class SocketConnectionImpl<Request extends AbstractRequest,Response extends AbstractResponse> extends SocketConnectionBase<Request,Response> implements ClientSocketConnection<Request,Response>
Disposable.Parent| Constructor and Description |
|---|
SocketConnectionImpl(java.net.InetAddress host,
int initialPort,
int portsNumberToTry,
RequestResponseExternalizerFactory<Request,Response> requestResponseRequestResponseExternalizerFactory) |
| Modifier and Type | Method and Description |
|---|---|
void |
connect() |
void |
open() |
void |
startPolling() |
addListener, addThreadToInterrupt, attachToSocket, close, dispose, getPort, getState, isStopping, onClosing, processRequests, registerHandler, removeThreadToInterrupt, sendRequest, sendRequest, sendRequest, setPort, setStatusclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddListener, close, getPort, getState, isStopping, registerHandler, sendRequest, sendRequest, sendRequestdisposepublic SocketConnectionImpl(java.net.InetAddress host,
int initialPort,
int portsNumberToTry,
RequestResponseExternalizerFactory<Request,Response> requestResponseRequestResponseExternalizerFactory)
public void open()
throws java.io.IOException
open in interface SocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>java.io.IOExceptionpublic void connect()
public void startPolling()
startPolling in interface ClientSocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>