com.devexperts.qd.qtp

Class AbstractConnectionHandler<C extends AbstractMessageConnector>

java.lang.Object

java.lang.Thread

com.devexperts.qd.qtp.QTPWorkerThread

com.devexperts.qd.qtp.AbstractConnectionHandler<C>

All Implemented Interfaces:

AbstractMessageConnector.Joinable, Runnable

public abstract class AbstractConnectionHandler<C extends AbstractMessageConnector>
extends QTPWorkerThread

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AbstractConnectionHandler.Factory

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected String	address
protected com.devexperts.transport.stats.ConnectionStats	connectionStats
protected C	connector

Fields inherited from class com.devexperts.qd.qtp.QTPWorkerThread

log

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractConnectionHandler(C connector)

Method Summary

Modifier and Type	Method and Description
protected abstract void	closeImpl(Throwable reason)
com.devexperts.transport.stats.ConnectionStats	getConnectionStats()
MessageConnectorState	getHandlerState()
protected void	handleClose(Throwable reason)
protected void	handleShutdown()
protected boolean	makeConnected()
protected void	setRemoteOptSet(MessageAdapter adapter, ProtocolOption.Set optSet)

Methods inherited from class com.devexperts.qd.qtp.QTPWorkerThread

close, doWork, isClosed, run

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.devexperts.qd.qtp.AbstractMessageConnector.Joinable

join

Field Detail

connector

protected final C extends AbstractMessageConnector connector

address

protected final String address

connectionStats

protected final com.devexperts.transport.stats.ConnectionStats connectionStats

Constructor Detail

AbstractConnectionHandler

protected AbstractConnectionHandler(C connector)

Method Detail

getConnectionStats

public final com.devexperts.transport.stats.ConnectionStats getConnectionStats()

getHandlerState

public final MessageConnectorState getHandlerState()

makeConnected

protected final boolean makeConnected()

handleShutdown

protected final void handleShutdown()

Specified by:

handleShutdown in class QTPWorkerThread

handleClose

protected final void handleClose(Throwable reason)

Specified by:

handleClose in class QTPWorkerThread

closeImpl

protected abstract void closeImpl(Throwable reason)

setRemoteOptSet

protected void setRemoteOptSet(MessageAdapter adapter,
                               ProtocolOption.Set optSet)