This commit is contained in:
zzz
2011-08-28 17:29:42 +00:00
parent c8a9d8ef35
commit 0c661b373e
2 changed files with 17 additions and 5 deletions

View File

@@ -46,6 +46,8 @@ public class DatabaseLookupMessage extends I2NPMessageImpl {
public DatabaseLookupMessage(I2PAppContext context) {
this(context, false);
}
/** @param locallyCreated ignored */
public DatabaseLookupMessage(I2PAppContext context, boolean locallyCreated) {
super(context);
//setSearchKey(null);

View File

@@ -16,19 +16,29 @@ import net.i2p.data.i2np.I2NPMessage;
*
*/
public interface MessageSelector {
/**
* Returns true if the received message matches the selector
* Returns true if the received message matches the selector.
* If this returns true, the job specified by OutNetMessage.getOnReplyJob()
* will be run for every OutNetMessage associated with this selector
* (by InNetMessagePool), after calling setMessage() for that ReplyJob.
*/
public boolean isMatch(I2NPMessage message);
/**
* Returns true if the selector should still keep searching for further matches
*
* Returns true if the selector should still keep searching for further matches.
* This is called only if isMatch() returns true.
* If this returns true, isMatch() will not be called again.
*/
public boolean continueMatching();
/**
* Returns the # of milliseconds since the epoch after which this selector should
* stop searching for matches
*
* stop searching for matches.
* At some time after expiration, if continueMatching() has not returned false,
* the job specified by OutNetMessage.getOnFailedReplyJob()
* will be run for every OutNetMessage associated with this selector
* (by OutboundMessageRegistry).
*/
public long getExpiration();
}