private class TcpSocketManager.Reconnector extends Log4jThread
| Modifier and Type | Field and Description |
|---|---|
private java.util.concurrent.CountDownLatch |
latch |
private java.lang.Object |
owner |
private boolean |
shutdown |
| Constructor and Description |
|---|
Reconnector(OutputStreamManager owner) |
| Modifier and Type | Method and Description |
|---|---|
private void |
connect(java.net.InetSocketAddress socketAddress) |
void |
latch() |
(package private) void |
reconnect() |
void |
run() |
void |
shutdown() |
java.lang.String |
toString() |
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, yieldprivate final java.util.concurrent.CountDownLatch latch
private boolean shutdown
private final java.lang.Object owner
public Reconnector(OutputStreamManager owner)
public void latch()
public void shutdown()
public void run()
run in interface java.lang.Runnablerun in class java.lang.Threadvoid reconnect()
throws java.io.IOException
java.io.IOExceptionprivate void connect(java.net.InetSocketAddress socketAddress)
throws java.io.IOException
java.io.IOExceptionpublic java.lang.String toString()
toString in class java.lang.Thread