Package 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.

Constructor Summary

Constructors

Constructor	Description
MessageReceiver(RouterContext ctx, UDPTransport transport)

Method Summary

Modifier and Type	Method	Description
void	loop(I2NPMessageHandler handler)
void	receiveMessage(InboundMessageState state)	This queues the message for processing.
void	shutdown()
void	startup()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MessageReceiver

public MessageReceiver(RouterContext ctx,
 UDPTransport transport)

Method Details

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)