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 theInboundMessageFragmentsqueue, parse 'em into I2NPMessages, and stick them on theInNetMessagePoolby way of theUDPTransport.
-
-
Constructor Summary
Constructors Constructor Description MessageReceiver(RouterContext ctx, UDPTransport transport)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidloop(I2NPMessageHandler handler)voidreceiveMessage(InboundMessageState state)This queues the message for processing.voidshutdown()voidstartup()
-
-
-
Constructor Detail
-
MessageReceiver
public MessageReceiver(RouterContext ctx, UDPTransport transport)
-
-
Method Detail
-
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)
-
-