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, setStatus
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addListener, close, getPort, getState, isStopping, registerHandler, sendRequest, sendRequest, sendRequest
dispose
public 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.IOException
public void connect()
public void startPolling()
startPolling
in interface ClientSocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>