osmq.broker.handlers
Class ServerSocketProcessor
java.lang.Object
osmq.util.Threaded
osmq.broker.handlers.ServerSocketProcessor
- All Implemented Interfaces:
- java.lang.Runnable
- public class ServerSocketProcessor
- extends Threaded
Listens for socket connections from publishers, subscribers, topic changers, and other
valid clients, passing each to a dedicated worker thread of the correct type.
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()
setWorkerClass
public void setWorkerClass(java.lang.Class workerclass,
java.lang.String role)
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()
upProcessCount
public void upProcessCount()
getChildProcessedCount
public int getChildProcessedCount()
addExceptionListener
public void addExceptionListener(ExceptionListener listener)
removeExceptionListener
public void removeExceptionListener(ExceptionListener listener)
isPauseChildren
public boolean isPauseChildren()