Package com.intellij.util.io.socketConnection.impl

Class SocketConnectionBase<Request extends AbstractRequest,Response extends AbstractResponse>

java.lang.Object

com.intellij.util.io.socketConnection.impl.SocketConnectionBase<Request,Response>

All Implemented Interfaces:

Disposable, SocketConnection<Request,Response>

Direct Known Subclasses:

ServerSocketConnectionImpl, SocketConnectionImpl

public abstract class SocketConnectionBase<Request extends AbstractRequest,Response extends AbstractResponse>
extends java.lang.Object
implements SocketConnection<Request,Response>

Nested Class Summary

Nested classes/interfaces inherited from interface com.intellij.openapi.Disposable

Disposable.Parent

Constructor Summary

Constructors

Constructor and Description
SocketConnectionBase(RequestResponseExternalizerFactory<Request,Response> factory)

Method Summary

Modifier and Type	Method and Description
void	addListener(SocketConnectionListener listener, Disposable parentDisposable)
protected void	addThreadToInterrupt()
protected void	attachToSocket(java.net.Socket socket)
void	close()
void	dispose() Usually not invoked directly, see class javadoc.
int	getPort()
ConnectionState	getState()
boolean	isStopping()
protected void	onClosing()
protected void	processRequests(RequestWriter<Request> writer)
<R extends Response> void	registerHandler(java.lang.Class<R> responseClass, AbstractResponseHandler<R> handler)
protected void	removeThreadToInterrupt()
void	sendRequest(Request request)
void	sendRequest(Request request, AbstractResponseToRequestHandler<? extends Response> handler)
void	sendRequest(Request request, AbstractResponseToRequestHandler<? extends Response> handler, int timeout, java.lang.Runnable onTimeout)
protected void	setPort(int port)
protected void	setStatus(ConnectionStatus status, java.lang.String message)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.intellij.util.io.socketConnection.SocketConnection

open

Constructor Detail

SocketConnectionBase

public SocketConnectionBase(RequestResponseExternalizerFactory<Request,Response> factory)

Method Detail

sendRequest

public void sendRequest(Request request)

Specified by:

sendRequest in interface SocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>

sendRequest

public void sendRequest(Request request,
                        AbstractResponseToRequestHandler<? extends Response> handler)

Specified by:

sendRequest in interface SocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>

sendRequest

public void sendRequest(Request request,
                        AbstractResponseToRequestHandler<? extends Response> handler,
                        int timeout,
                        java.lang.Runnable onTimeout)

Specified by:

sendRequest in interface SocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>

registerHandler

public <R extends Response> void registerHandler(java.lang.Class<R> responseClass,
                                                 AbstractResponseHandler<R> handler)

Specified by:

registerHandler in interface SocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>

isStopping

public boolean isStopping()

Specified by:

isStopping in interface SocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>

processRequests

protected void processRequests(RequestWriter<Request> writer)
                        throws java.io.IOException

Throws:

java.io.IOException

addThreadToInterrupt

protected void addThreadToInterrupt()

removeThreadToInterrupt

protected void removeThreadToInterrupt()

dispose

public void dispose()

Description copied from interface: Disposable

Usually not invoked directly, see class javadoc.

Specified by:

dispose in interface Disposable

getPort

public int getPort()

Specified by:

getPort in interface SocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>

setStatus

protected void setStatus(ConnectionStatus status,
                         java.lang.String message)

getState

public ConnectionState getState()

Specified by:

getState in interface SocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>

addListener

public void addListener(SocketConnectionListener listener,
                        Disposable parentDisposable)

Specified by:

addListener in interface SocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>

close

public void close()

Specified by:

close in interface SocketConnection<Request extends AbstractRequest,Response extends AbstractResponse>

onClosing

protected void onClosing()

attachToSocket

protected void attachToSocket(java.net.Socket socket)
                       throws java.io.IOException

Throws:

java.io.IOException

setPort

protected void setPort(int port)