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

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 Details

QueuedI2CPMessageReaderRunner

public QueuedI2CPMessageReaderRunner()

Method Details

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