osmq.net
Class ServerSocketProcessor
java.lang.Object
osmq.util.Threaded
osmq.net.ServerSocketProcessor
- All Implemented Interfaces:
- java.lang.Runnable
- public abstract class ServerSocketProcessor
- extends Threaded
Base class for socket server class that listens for publisher and subscriber
connections, passing them to a dedicated thread.
Methods inherited from class osmq.util.Threaded |
getExceptionListener, getIterations, getPriority, getSequenceNumber, getUserDefinedName, getYieldToPeers, hasTerminated, isPaused, isRunning, isShutdownCompleted, killAll, killAllInGroup, run, setExceptionListener, setPaused, setPriority, setUserDefinedName, setYieldCount, shutdownRequested, sleepSecs, sleepTenths, start, stop, successfulInit |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ServerSocketProcessor
public ServerSocketProcessor(java.net.ServerSocket ss)
throws java.io.IOException
ServerSocketProcessor
public ServerSocketProcessor()
setBinarySocketMode
public void setBinarySocketMode(boolean binary)
- if binary is true, the socket will
be opened in binary content mode. Otherwise, socket
will be opened in text mode.
isBinarySocketMode
public boolean isBinarySocketMode()
setPortID
public void setPortID(int v)
getPortID
public int getPortID()
addExceptionListener
public void addExceptionListener(ExceptionListener listener)
removeExceptionListener
public void removeExceptionListener(ExceptionListener listener)