OSMQ
v2.0.1

osmq.broker.handlers
Class ServerSocketProcessor

java.lang.Object
  extended byosmq.util.Threaded
      extended byosmq.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.


Field Summary
 
Fields inherited from class osmq.util.Threaded
HIGH_PRIORITY, HIGHEST_PRIORITY, INCREASED_PRIORITY, VERY_HIGH_PRIORITY
 
Constructor Summary
ServerSocketProcessor()
           
ServerSocketProcessor(java.net.ServerSocket ss)
           
 
Method Summary
 void addExceptionListener(ExceptionListener listener)
           
 int getChildProcessedCount()
           
 int getPortID()
           
 boolean isBinarySocketMode()
           
 boolean isPauseChildren()
           
 void removeExceptionListener(ExceptionListener listener)
           
 void setBinarySocketMode(boolean binary)
          if binary is true, the socket will be opened in binary content mode.
 void setPortID(int v)
           
 void setWorkerClass(java.lang.Class workerclass, java.lang.String role)
           
 void upProcessCount()
           
 
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
 

Constructor Detail

ServerSocketProcessor

public ServerSocketProcessor(java.net.ServerSocket ss)
                      throws java.io.IOException

ServerSocketProcessor

public ServerSocketProcessor()
Method Detail

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()

(c) 2000 - 2003 MQue Systems
All Rights Reserved