OSMQ
v2.0.1

osmq.net
Class ServerSocketProcessor

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


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 getPortID()
           
 boolean isBinarySocketMode()
           
 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)
           
 
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

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)

(c) 2000 - 2003 MQue Systems
All Rights Reserved