Package net.i2p.internal
Class QueuedI2CPMessageReader.QueuedI2CPMessageReaderRunner
java.lang.Object
net.i2p.data.i2cp.I2CPMessageReader.I2CPMessageReaderRunner
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
Constructors Constructor Description QueuedI2CPMessageReaderRunner()
-
Method Summary
Modifier and Type Method Description 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
-
Constructor Details
-
QueuedI2CPMessageReaderRunner
public QueuedI2CPMessageReaderRunner()
-
-
Method Details
-
cancelRunner
public void cancelRunner()Shuts the pumper down.- Overrides:
cancelRunner
in classI2CPMessageReader.I2CPMessageReaderRunner
-
run2
protected void run2()Pumps messages from the incoming message queue to the listener.- Overrides:
run2
in classI2CPMessageReader.I2CPMessageReaderRunner
-