Skip to content

Commit 5d1baa4

Browse files
committed
[TASK] Add log message when processing a IndexingJob
1 parent 06b5b49 commit 5d1baa4

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

  • Classes/Flowpack/ElasticSearch/ContentRepositoryQueueIndexer

Classes/Flowpack/ElasticSearch/ContentRepositoryQueueIndexer/IndexingJob.php

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,8 @@
22
namespace Flowpack\ElasticSearch\ContentRepositoryQueueIndexer;
33

44
use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Indexer\NodeIndexer;
5-
use Flowpack\ElasticSearch\ContentRepositoryAdaptor\LoggerInterface;
65
use TYPO3\Flow\Annotations as Flow;
6+
use TYPO3\Flow\Log\SystemLoggerInterface;
77
use TYPO3\Flow\Utility\Algorithms;
88
use TYPO3\Jobqueue\Common\Job\JobInterface;
99
use TYPO3\Jobqueue\Common\Queue\Message;
@@ -44,7 +44,7 @@ class IndexingJob implements JobInterface {
4444
protected $contextFactory;
4545

4646
/**
47-
* @var LoggerInterface
47+
* @var SystemLoggerInterface
4848
* @Flow\Inject
4949
*/
5050
protected $logger;
@@ -102,6 +102,7 @@ public function execute(QueueInterface $queue, Message $message) {
102102
return TRUE;
103103
}
104104
$this->nodeIndexer->setIndexNamePostfix($this->indexPostfix);
105+
$this->logger->log(sprintf('Process indexing job for %s', $currentNode));
105106
$this->nodeIndexer->indexNode($currentNode);
106107
}
107108

0 commit comments

Comments
 (0)