* @param $responseInstance An instance of a class with an Responseable interface
* @return void
* @throws FilterChainException If the filter chain needs to be interrupted
- * @todo 5% done
+ * @todo 10% done
*/
public function execute (Requestable $requestInstance, Responseable $responseInstance) {
// Get crawler instance
$taskInstance = ObjectFactory::createObjectByConfiguredName('crawler_node_communicator_task_class');
$handlerInstance->registerTask('crawler_node_communicator', $taskInstance);
- // 2) Local URL fetcher (fetches URLs locally and adds them to the analyzer's input stack)
- $taskInstance = ObjectFactory::createObjectByConfiguredName('crawler_local_url_fetcher_task_class');
- $handlerInstance->registerTask('crawler_local_url_fetcher', $taskInstance);
+ // 2) Local URL getter (gets URLs locally and adds them to the analyzer's input stack)
+ $taskInstance = ObjectFactory::createObjectByConfiguredName('crawler_local_url_getter_task_class');
+ $handlerInstance->registerTask('crawler_local_url_getter', $taskInstance);
- // 3) Remote URL fetcher (let fetch URLs by other crawler nodes and also adds them to the stack)
- $taskInstance = ObjectFactory::createObjectByConfiguredName('crawler_remote_url_fetcher_task_class');
- $handlerInstance->registerTask('crawler_remote_url_fetcher', $taskInstance);
+ // 3) Remote URL getter (gets URLs locally for other nodes, also includes the crawled URL in local index)
+ $taskInstance = ObjectFactory::createObjectByConfiguredName('crawler_remote_url_getter_task_class');
+ $handlerInstance->registerTask('crawler_remote_url_getter', $taskInstance);
+
+ // 4) Remote-crawl publisher (publishes crawl jobs for remote retrieval)
+ $taskInstance = ObjectFactory::createObjectByConfiguredName('crawler_remote_job_publisher_task_class');
+ $handlerInstance->registerTask('crawler_remote_job_publisher', $taskInstance);
// Put the task handler in registry
Registry::getRegistry()->addInstance('task_handler', $handlerInstance);