OSMQ
v2.0.1

osmq.util
Class ThreadedReader

java.lang.Object
  extended byosmq.util.Threaded
      extended byosmq.util.ThreadedReader
All Implemented Interfaces:
java.lang.Runnable

public class ThreadedReader
extends Threaded


Field Summary
 
Fields inherited from class osmq.util.Threaded
HIGH_PRIORITY, HIGHEST_PRIORITY, INCREASED_PRIORITY, VERY_HIGH_PRIORITY
 
Constructor Summary
ThreadedReader()
           
ThreadedReader(Readable device)
           
 
Method Summary
 void close()
           
 DataRecord getDataRecord()
           
 Readable getDevice()
           
 FilterListener getFilterListener()
           
 Message getMessage()
           
 byte[] getNext()
           
 Writable getOutputQueue()
           
 java.lang.String getString()
           
 void open()
           
 void setDevice(Readable device)
           
 void setFilterListener(FilterListener fl)
           
 void setOutputQueue(Writable q)
           
 
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

ThreadedReader

public ThreadedReader()

ThreadedReader

public ThreadedReader(Readable device)
Method Detail

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

(c) 2000 - 2003 MQue Systems
All Rights Reserved