net.i2p.router.transport
Class OutboundMessageRegistry
java.lang.Object
net.i2p.router.transport.OutboundMessageRegistry
public class OutboundMessageRegistry
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
OutboundMessageRegistry
public OutboundMessageRegistry(RouterContext context)
shutdown
public void shutdown()
getOriginalMessages
public java.util.List getOriginalMessages(I2NPMessage message)
- Retrieve all messages that are waiting for the specified message. In
addition, those matches may include instructions to either continue or not
continue waiting for further replies - if it should continue, the matched
message remains in the registry, but if it shouldn't continue, the matched
message is removed from the registry.
- Parameters:
message
- Payload received that may be a reply to something we sent
- Returns:
- List of OutNetMessage describing messages that were waiting for
the payload
registerPending
public OutNetMessage registerPending(MessageSelector replySelector,
ReplyJob onReply,
Job onTimeout,
int timeoutMs)
registerPending
public void registerPending(OutNetMessage msg)
registerPending
public void registerPending(OutNetMessage msg,
boolean allowEmpty)
unregisterPending
public void unregisterPending(OutNetMessage msg)
renderStatusHTML
public void renderStatusHTML(java.io.Writer out)
throws java.io.IOException
- Throws:
java.io.IOException