osmq.util
Class ThreadedReader
java.lang.Object
osmq.util.Threaded
osmq.util.ThreadedReader
- All Implemented Interfaces:
- java.lang.Runnable
- public class ThreadedReader
- 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 |
ThreadedReader
public ThreadedReader()
ThreadedReader
public ThreadedReader(Readable device)
setDevice
public void setDevice(Readable device)
getDevice
public Readable getDevice()
setFilterListener
public void setFilterListener(FilterListener fl)
getFilterListener
public FilterListener getFilterListener()
setOutputQueue
public void setOutputQueue(Writable q)
getOutputQueue
public Writable getOutputQueue()
getNext
public byte[] getNext()
throws java.io.IOException
- Throws:
java.io.IOException
getString
public final java.lang.String getString()
throws java.io.IOException
- Throws:
java.io.IOException
getDataRecord
public DataRecord getDataRecord()
throws java.io.IOException
- Throws:
java.io.IOException
getMessage
public Message getMessage()
throws java.io.IOException,
MessageException
- Throws:
java.io.IOException
MessageException
close
public void close()
open
public void open()