public class InNetMessagePool extends Object implements Service
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 |
add(I2NPMessage messageBody,
RouterIdentity fromRouter,
Hash fromRouterHash,
long msgIDBloomXor)
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
|
public InNetMessagePool(RouterContext context)
public HandlerJobBuilder registerHandlerJobBuilder(int i2npMessageType, HandlerJobBuilder builder)
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 add(I2NPMessage messageBody, RouterIdentity fromRouter, Hash fromRouterHash, long msgIDBloomXor)
messageBody
- non-nullfromRouter
- may be nullfromRouterHash
- may be null, calculated from fromRouter if nullmsgIDBloomXor
- constant value to XOR with the messageID before passing to the bloom filter.public int handleReplies(I2NPMessage messageBody)
public void renderStatusHTML(Writer out)
renderStatusHTML
in interface Service
public void restart()
public void shutdown()