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 theInboundMessageFragments
queue, parse 'em into I2NPMessages, and stick them on theInNetMessagePool
by 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 void
loop(I2NPMessageHandler handler)
void
receiveMessage(InboundMessageState state)
This queues the message for processing.void
shutdown()
void
startup()
-
-
-
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)
-
-