net.i2p.router.transport.udp
Class MessageReceiver
java.lang.Object
net.i2p.router.transport.udp.MessageReceiver
class MessageReceiver
- extends Object
Pull fully completed fragments off the InboundMessageFragments
queue,
parse 'em into I2NPMessages, and stick them on the
InNetMessagePool
by way of the UDPTransport
.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MessageReceiver
public MessageReceiver(RouterContext ctx,
UDPTransport transport)
startup
public void startup()
shutdown
public void shutdown()
receiveMessage
public void receiveMessage(InboundMessageState state)
- This queues the message for processing.
Processing will call state.releaseResources(), do not access state after calling this.
BLOCKING if queue is full.
loop
public void loop(I2NPMessageHandler handler)