Job
IterativeFollowupJob
class SingleSearchJob extends FloodOnlySearchJob
_onReply, _onTimeout, _replySelector
_created, _dead, _expiration, _facade, _isLease, _key, _log, _lookupsRemaining, _onFailed, _onFind, _success, _timeoutMs, CONCURRENT_SEARCHES
Constructor | Description |
---|---|
SingleSearchJob(RouterContext ctx,
Hash key,
Hash to) |
Modifier and Type | Method | Description |
---|---|---|
(package private) void |
failed() |
Deprecated, unused, see FOSJ override
|
String |
getName() |
Deprecated, unused, see FOSJ override
|
void |
runJob() |
Deprecated, unused, see FOSJ override
|
boolean |
shouldProcessDSRM() |
|
(package private) void |
success() |
Deprecated, unused, see FOSJ override
|
decrementRemaining
addDeferred, decrementRemaining, getCreated, getExpiration, getKey, getLookupsRemaining
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
public SingleSearchJob(RouterContext ctx, Hash key, Hash to)
key
- for Router Info ONLYpublic String getName()
FloodSearchJob
getName
in interface Job
getName
in class FloodOnlySearchJob
public boolean shouldProcessDSRM()
shouldProcessDSRM
in class FloodOnlySearchJob
public void runJob()
FloodSearchJob
runJob
in interface Job
runJob
in class FloodOnlySearchJob
void failed()
FloodSearchJob
failed
in class FloodOnlySearchJob
void success()
FloodSearchJob
success
in class FloodOnlySearchJob