Package com.crawljax.core
Class CrawlTaskConsumer
- java.lang.Object
-
- com.crawljax.core.CrawlTaskConsumer
-
public class CrawlTaskConsumer extends Object implements Callable<Void>
ConsumesStateVertexs it gets from theUnfiredCandidateActions. It delegates the actual browser interactions to aCrawlerwhom it has a 1 to 1 relation with.
-
-
Field Summary
Fields Modifier and Type Field Description private UnfiredFragmentCandidatescandidatesprivate Crawlercrawlerprivate ExitNotifierexitNotifierprivate static org.slf4j.LoggerLOGprivate AtomicIntegerrunningConsumers
-
Constructor Summary
Constructors Constructor Description CrawlTaskConsumer(UnfiredFragmentCandidates candidates, ExitNotifier exitNotifier, Crawler crawler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Voidcall()StateVertexcrawlIndex()This method calls the index state.CrawlerContextgetContext()private voidhandleTask(StateVertex state)private voidpollAndHandleCrawlTasks()
-
-
-
Field Detail
-
LOG
private static final org.slf4j.Logger LOG
-
runningConsumers
private final AtomicInteger runningConsumers
-
crawler
private final Crawler crawler
-
candidates
private final UnfiredFragmentCandidates candidates
-
exitNotifier
private final ExitNotifier exitNotifier
-
-
Constructor Detail
-
CrawlTaskConsumer
@Inject CrawlTaskConsumer(UnfiredFragmentCandidates candidates, ExitNotifier exitNotifier, Crawler crawler)
-
-
Method Detail
-
pollAndHandleCrawlTasks
private void pollAndHandleCrawlTasks() throws InterruptedException- Throws:
InterruptedException
-
handleTask
private void handleTask(StateVertex state)
-
crawlIndex
public StateVertex crawlIndex()
This method calls the index state. It should be called once in order to setup the crawl.- Returns:
- The initial state.
-
getContext
public CrawlerContext getContext()
-
-