Service
public class InNetMessagePool extends Object implements Service
Modifier and Type | Field | Description |
---|---|---|
static boolean |
DEFAULT_DISPATCH_THREADED |
|
static String |
PROP_DISPATCH_THREADED |
If set to true, we will have two additional threads - one for dispatching
tunnel data messages, and another for dispatching tunnel gateway messages.
|
Constructor | Description |
---|---|
InNetMessagePool(RouterContext context) |
Modifier and Type | Method | Description |
---|---|---|
int |
add(I2NPMessage messageBody,
RouterIdentity fromRouter,
Hash fromRouterHash) |
Add a new message to the pool.
|
int |
handleReplies(I2NPMessage messageBody) |
|
HandlerJobBuilder |
registerHandlerJobBuilder(int i2npMessageType,
HandlerJobBuilder builder) |
|
void |
renderStatusHTML(Writer out) |
|
void |
restart() |
does nothing since we aren't threaded
|
void |
shutdown() |
does nothing since we aren't threaded
|
void |
startup() |
does nothing since we aren't threaded
|
HandlerJobBuilder |
unregisterHandlerJobBuilder(int i2npMessageType) |
Deprecated.
unused
|
public static final String PROP_DISPATCH_THREADED
public static final boolean DEFAULT_DISPATCH_THREADED
public InNetMessagePool(RouterContext context)
public HandlerJobBuilder registerHandlerJobBuilder(int i2npMessageType, HandlerJobBuilder builder)
ArrayIndexOutOfBoundsException
- if i2npMessageType is greater than MAX_I2NP_MESSAGE_TYPE@Deprecated public HandlerJobBuilder unregisterHandlerJobBuilder(int i2npMessageType)
ArrayIndexOutOfBoundsException
- if i2npMessageType is greater than MAX_I2NP_MESSAGE_TYPEpublic int add(I2NPMessage messageBody, RouterIdentity fromRouter, Hash fromRouterHash)
messageBody
- non-nullfromRouter
- may be nullfromRouterHash
- may be null, calculated from fromRouter if nullpublic int handleReplies(I2NPMessage messageBody)
public void renderStatusHTML(Writer out)
renderStatusHTML
in interface Service
public void restart()
public void shutdown()