public class OutboundMessageRegistry extends Object
Constructor | Description |
---|---|
OutboundMessageRegistry(RouterContext context) |
Modifier and Type | Method | Description |
---|---|---|
List<OutNetMessage> |
getOriginalMessages(I2NPMessage message) |
Retrieve all messages that are waiting for the specified message.
|
OutNetMessage |
registerPending(MessageSelector replySelector,
ReplyJob onReply,
Job onTimeout) |
Registers a new, empty OutNetMessage, with the reply and timeout jobs specified.
|
void |
registerPending(OutNetMessage msg) |
Register the message.
|
void |
renderStatusHTML(Writer out) |
Deprecated.
unused
|
void |
restart() |
|
void |
shutdown() |
Does something @since 0.8.8
|
void |
unregisterPending(OutNetMessage msg) |
public OutboundMessageRegistry(RouterContext context)
public void shutdown()
public void restart()
public List<OutNetMessage> getOriginalMessages(I2NPMessage message)
message
- Payload received that may be a reply to something we sentpublic OutNetMessage registerPending(MessageSelector replySelector, ReplyJob onReply, Job onTimeout)
replySelector
- non-null; The same selector may be used for more than one message.onReply
- non-nullonTimeout
- may be nullpublic void registerPending(OutNetMessage msg)
msg
- msg.getMessage() and msg.getReplySelector() must be non-nullpublic void unregisterPending(OutNetMessage msg)
msg
- may be be null@Deprecated public void renderStatusHTML(Writer out) throws IOException
IOException