TASK: Require next version of jobqueue-common and change interfaces accordingly

Author: daniellienert

Classes/IndexingJob.php

@@ -29,7 +29,7 @@ class IndexingJob extends AbstractIndexingJob
      * @return boolean TRUE if the job was executed successfully and the message should be finished
      * @throws \Exception
      */
-    public function execute(QueueInterface $queue, Message $message)
+    public function execute(QueueInterface $queue, Message $message): bool
     {
         $this->nodeIndexer->withBulkProcessing(function () {
             $numberOfNodes = count($this->nodes);
@@ -76,7 +76,7 @@ public function execute(QueueInterface $queue, Message $message)
      *
      * @return string A label for the job
      */
-    public function getLabel()
+    public function getLabel(): string
     {
         return sprintf('Elasticsearch Indexing Job (%s)', $this->getIdentifier());
     }

Classes/RemovalJob.php

@@ -30,7 +30,7 @@ class RemovalJob extends AbstractIndexingJob
      * @return boolean TRUE if the job was executed successfully and the message should be finished
      * @throws \Exception
      */
-    public function execute(QueueInterface $queue, Message $message)
+    public function execute(QueueInterface $queue, Message $message): bool
     {
         $this->nodeIndexer->withBulkProcessing(function () {
             $numberOfNodes = count($this->nodes);
@@ -85,7 +85,7 @@ public function execute(QueueInterface $queue, Message $message)
      *
      * @return string A label for the job
      */
-    public function getLabel()
+    public function getLabel(): string
     {
         return sprintf('Elasticsearch Removal Job (%s)', $this->getIdentifier());
     }

Classes/UpdateAliasJob.php

@@ -58,7 +58,7 @@ public function __construct($indexPostfix)
      * @throws \Flowpack\ElasticSearch\ContentRepositoryAdaptor\Exception
      * @throws \Flowpack\ElasticSearch\Transfer\Exception\ApiException
      */
-    public function execute(QueueInterface $queue, Message $message)
+    public function execute(QueueInterface $queue, Message $message): bool
     {
         $this->nodeIndexer->setIndexNamePostfix($this->indexPostfix);
         $this->nodeIndexer->updateIndexAlias();
@@ -82,7 +82,7 @@ public function getIdentifier()
      *
      * @return string A label for the job
      */
-    public function getLabel()
+    public function getLabel(): string
     {
         return sprintf('ElasticSearch Indexing Job (%s)', $this->getIdentifier());
     }

composer.json

@@ -4,8 +4,8 @@
   "description": "Neos CMS Elasticsearch indexer based on a job queue",
   "license": "MIT",
   "require": {
-    "flowpack/jobqueue-common": "^2.0.0",
-    "flowpack/elasticsearch-contentrepositoryadaptor": "^4.0.0"
+    "flowpack/jobqueue-common": "^3.0 || dev-master",
+    "flowpack/elasticsearch-contentrepositoryadaptor": "^4.0"
   },
   "autoload": {
     "psr-4": {