public class InNetMessagePool extends Object implements Service
Modifier and Type | Field and 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 and Description |
---|
InNetMessagePool(RouterContext context) |
Modifier and Type | Method and 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()