|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.router.transport.OutboundMessageRegistry
public class OutboundMessageRegistry
Tracks outbound messages.
Constructor Summary | |
---|---|
OutboundMessageRegistry(RouterContext context)
|
Method Summary | |
---|---|
List<OutNetMessage> |
getOriginalMessages(I2NPMessage message)
Retrieve all messages that are waiting for the specified message. |
OutNetMessage |
registerPending(MessageSelector replySelector,
ReplyJob onReply,
Job onTimeout,
int timeoutMs)
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)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public OutboundMessageRegistry(RouterContext context)
Method Detail |
---|
public void shutdown()
public void restart()
public List<OutNetMessage> getOriginalMessages(I2NPMessage message)
message
- Payload received that may be a reply to something we sent
public OutNetMessage registerPending(MessageSelector replySelector, ReplyJob onReply, Job onTimeout, int timeoutMs)
replySelector
- non-null; The same selector may be used for more than one message.onReply
- may be nullonTimeout
- Also called on failed send; may be null
public void registerPending(OutNetMessage msg)
msg
- msg.getMessage() and msg.getReplySelector() must be non-nullpublic void unregisterPending(OutNetMessage msg)
msg
- may be be nullpublic void renderStatusHTML(Writer out) throws IOException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |