net.i2p.internal
Class QueuedI2CPMessageReader.QueuedI2CPMessageReaderRunner

java.lang.Object
  extended by net.i2p.data.i2cp.I2CPMessageReader.I2CPMessageReaderRunner
      extended by net.i2p.internal.QueuedI2CPMessageReader.QueuedI2CPMessageReaderRunner
All Implemented Interfaces:
Runnable
Enclosing class:
QueuedI2CPMessageReader

protected class QueuedI2CPMessageReader.QueuedI2CPMessageReaderRunner
extends I2CPMessageReader.I2CPMessageReaderRunner
implements Runnable


Field Summary
 
Fields inherited from class net.i2p.data.i2cp.I2CPMessageReader.I2CPMessageReaderRunner
_doRun, _stayAlive
 
Constructor Summary
QueuedI2CPMessageReader.QueuedI2CPMessageReaderRunner()
           
 
Method Summary
 void cancelRunner()
          Shuts the pumper down.
protected  void run2()
          Pumps messages from the incoming message queue to the listener.
 
Methods inherited from class net.i2p.data.i2cp.I2CPMessageReader.I2CPMessageReaderRunner
pauseRunner, resumeRunner, run
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface java.lang.Runnable
run
 

Constructor Detail

QueuedI2CPMessageReader.QueuedI2CPMessageReaderRunner

public QueuedI2CPMessageReader.QueuedI2CPMessageReaderRunner()
Method Detail

cancelRunner

public void cancelRunner()
Shuts the pumper down.

Overrides:
cancelRunner in class I2CPMessageReader.I2CPMessageReaderRunner

run2

protected void run2()
Pumps messages from the incoming message queue to the listener.

Overrides:
run2 in class I2CPMessageReader.I2CPMessageReaderRunner