osmq.broker.handlers
Class ServiceHandler
java.lang.Object
osmq.util.Threaded
osmq.broker.handlers.ServiceHandler
- All Implemented Interfaces:
- java.lang.Runnable
- Direct Known Subclasses:
- ChangeHandler, PublisherHandler, RecoveryHandler, SubscriberHandler, TopicChangeHandler
- public abstract class ServiceHandler
- extends Threaded
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 |
ServiceHandler
public ServiceHandler()
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