Package org.openas2.processor.receiver
Class NetModule.HTTPServerThread
- java.lang.Object
-
- java.lang.Thread
-
- org.openas2.processor.receiver.NetModule.HTTPServerThread
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- NetModule
protected class NetModule.HTTPServerThread extends java.lang.Thread
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.ExecutorServiceconnectionThreadsprivate NetModuleownerprivate java.net.ServerSocketsocketprivate java.util.concurrent.atomic.AtomicBooleanterminated
-
Constructor Summary
Constructors Constructor Description HTTPServerThread(NetModule owner, java.lang.String address, int port)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) NetModulegetOwner()java.net.ServerSocketgetSocket()booleanisTerminated()voidrun()voidterminate()-
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
-
-
-
-
Field Detail
-
owner
private final NetModule owner
-
socket
private final java.net.ServerSocket socket
-
connectionThreads
private final java.util.concurrent.ExecutorService connectionThreads
-
terminated
private final java.util.concurrent.atomic.AtomicBoolean terminated
-
-
Constructor Detail
-
HTTPServerThread
HTTPServerThread(NetModule owner, @Nullable java.lang.String address, int port) throws java.io.IOException
- Throws:
java.io.IOException
-
-
Method Detail
-
getOwner
NetModule getOwner()
-
getSocket
public java.net.ServerSocket getSocket()
-
isTerminated
public boolean isTerminated()
-
terminate
public void terminate()
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable- Overrides:
runin classjava.lang.Thread
-
-