OSMQ
v2.0.1

osmq.broker.handlers
Class ServiceHandler

java.lang.Object
  extended byosmq.util.Threaded
      extended byosmq.broker.handlers.ServiceHandler
All Implemented Interfaces:
java.lang.Runnable
Direct Known Subclasses:
ChangeHandler, PublisherHandler, RecoveryHandler, SubscriberHandler, TopicChangeHandler

public abstract class ServiceHandler
extends Threaded


Field Summary
 
Fields inherited from class osmq.util.Threaded
HIGH_PRIORITY, HIGHEST_PRIORITY, INCREASED_PRIORITY, VERY_HIGH_PRIORITY
 
Constructor Summary
ServiceHandler()
           
 
Method Summary
 java.lang.String getRemoteIPString()
           
 SocketStreamFilter getStreamFilter()
           
 void println(java.lang.String s)
          Writes a String value to the socket stream.
 byte[] readBytes()
           
 java.lang.String readln()
           
 void setParent(ServerSocketProcessor ssp)
           
 void setStreamFilter(SocketStreamFilter sw)
           
 void writeBytes(byte[] b)
           
 
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

ServiceHandler

public ServiceHandler()
Method Detail

setParent

public void setParent(ServerSocketProcessor ssp)

setStreamFilter

public void setStreamFilter(SocketStreamFilter sw)

getStreamFilter

public SocketStreamFilter getStreamFilter()

getRemoteIPString

public java.lang.String getRemoteIPString()

readln

public java.lang.String readln()
                        throws java.io.IOException
Throws:
java.io.IOException

readBytes

public byte[] readBytes()
                 throws java.io.IOException
Throws:
java.io.IOException

writeBytes

public void writeBytes(byte[] b)
                throws java.io.IOException
Throws:
java.io.IOException

println

public void println(java.lang.String s)
             throws java.io.IOException
Writes a String value to the socket stream.

Throws:
java.io.IOException

(c) 2000 - 2003 MQue Systems
All Rights Reserved