MessageReceiver (Javadocs [I2P+ 2.13.0+]

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. Supports dynamic thread count adjustment via setThreadCount(int).

Constructor Summary
Constructors
Constructor and Description
MessageReceiver(RouterContext ctx, UDPTransport transport)
MessageReceiver.

Constructors
Constructor and Description
`MessageReceiver(RouterContext ctx, UDPTransport transport)` MessageReceiver.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`(package private) void`	`adjustThreads()` Dynamically adjust thread count.
`int`	`getProcessingCount()` Returns the number of runners actively processing messages (not parked on take()).
`int`	`getQueueCapacity()` Returns the maximum capacity of the message receiver queue.
`int`	`getQueueSize()` Returns the current queue depth of the message receiver.
`static int`	`getThreadCount()` Returns the current target thread count.
`double`	`getUtilization()` Get message receiver pool utilization as a ratio (0.0-1.0).
`(package private) void`	`loop(I2NPMessageHandler handler)` Main processing loop.
`void`	`receiveMessage(InboundMessageState state)` This queues the message for processing.
`static void`	`setThreadCount(int count)` Sets the target thread count.
`void`	`shutdown()` shutdown.
`void`	`startup()` startup.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - MessageReceiver
```
public MessageReceiver(RouterContext ctx,
                       UDPTransport transport)
```
    MessageReceiver.
- Method Detail
  - adjustThreads
```
void adjustThreads()
```
    Dynamically adjust thread count. If target is higher than current, start new runners. If lower, poison excess runners.
  - getProcessingCount
```
public int getProcessingCount()
```
    Returns the number of runners actively processing messages (not parked on take()).
    Returns:
    the processing count
  - getQueueCapacity
```
public int getQueueCapacity()
```
    Returns the maximum capacity of the message receiver queue.
    Returns:
    the queue capacity
  - getQueueSize
```
public int getQueueSize()
```
    Returns the current queue depth of the message receiver.
    Returns:
    the queue size
  - getThreadCount
```
public static int getThreadCount()
```
    Returns the current target thread count.
    Returns:
    the thread count
  - getUtilization
```
public double getUtilization()
```
    Get message receiver pool utilization as a ratio (0.0-1.0). Returns NaN if not started.
    Returns:
    the utilization
  - loop
```
void loop(I2NPMessageHandler handler)
```
    Main processing loop. Pulls completed messages from the queue, parses them into I2NPMessages, and delivers them to the transport.
  - 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.
  - setThreadCount
```
public static void setThreadCount(int count)
```
    Sets the target thread count. Takes effect immediately — excess threads will exit, new threads will be started if needed.
  - shutdown
```
public void shutdown()
```
    shutdown.
  - startup
```
public void startup()
```
    startup.

Class MessageReceiver

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

MessageReceiver

Method Detail

adjustThreads

getProcessingCount

getQueueCapacity

getQueueSize

getThreadCount

getUtilization

loop

receiveMessage

setThreadCount

shutdown

startup