public class OutboundMessageRegistry extends Object
Constructor and Description |
---|
OutboundMessageRegistry(RouterContext context) |
Modifier and Type | Method and 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