Using consume method

Author: mcop1

tests/Functional/SearchIndex/AssetBasicTest.php

@@ -81,8 +81,7 @@ public function testFolderIndexingAsynchronous()
         $folder->setKey('my-test-folder');
         $folder->save();
 
-        //Since the queue is processed asynchronously we need to run the worker here
-        $this->tester->runCommand('messenger:consume', ['--limit'=>2], ['pimcore_generic_data_index_queue']);
+        $this->tester->consume();
 
         $this->assertGreaterThan(
             0,

tests/Functional/SearchIndex/DataObjectBasicTest.php

@@ -99,8 +99,7 @@ public function testIndexingWithInheritanceAsynchronous()
         $child = $this->createChildObject($object);
         $indexName = $this->dataObjectTypeAdapter->getAliasIndexName($object->getClass());
 
-        //Since the queue is processed asynchronously we need to run the worker here
-        $this->tester->runCommand('messenger:consume', ['--limit'=>2], ['pimcore_generic_data_index_queue']);
+        $this->tester->consume();
 
         // check indexed
         $this->assertGreaterThan(
@@ -127,8 +126,7 @@ public function testIndexingWithInheritanceAsynchronousNoInheritance()
         $child = $this->createChildObject($object);
         $indexName = $this->dataObjectTypeAdapter->getAliasIndexName($object->getClass());
 
-        //Since the queue is processed asynchronously we need to run the worker here
-        $this->tester->runCommand('messenger:consume', ['--limit'=>2], ['pimcore_generic_data_index_queue']);
+        $this->tester->consume();
 
         // check indexed
         $this->assertGreaterThan(
@@ -181,8 +179,7 @@ public function testIndexingWithoutInheritanceAsynchronous()
         $this->assertFalse($object->getClass()->getAllowInherit());
         $indexName = $this->dataObjectTypeAdapter->getAliasIndexName($object->getClass());
 
-        //Since the queue is processed asynchronously we need to run the worker here
-        $this->tester->runCommand('messenger:consume', ['--limit'=>2], ['pimcore_generic_data_index_queue']);
+        $this->tester->consume();
 
         // check indexed
         $this->assertGreaterThan(
@@ -226,8 +223,7 @@ public function testFolderIndexingAsynchronous()
         $object->setKey('my-test-folder');
         $object->save();
 
-        //Since the queue is processed asynchronously we need to run the worker here
-        $this->tester->runCommand('messenger:consume', ['--limit'=>2], ['pimcore_generic_data_index_queue']);
+        $this->tester->consume();
 
         $this->assertGreaterThan(
             0,

tests/Functional/SearchIndex/DocumentBasicTest.php

@@ -83,8 +83,7 @@ public function testFolderIndexingAsynchronous()
         $folder->setKey('my-test-folder');
         $folder->save();
 
-        //Since the queue is processed asynchronously we need to run the worker here
-        $this->tester->runCommand('messenger:consume', ['--limit'=>2], ['pimcore_generic_data_index_queue']);
+        $this->tester->consume();
 
         $this->assertGreaterThan(
             0,

tests/Functional/SearchIndex/IndexQueueTest.php

@@ -72,8 +72,7 @@ public function testIndexQueueRepository(): void
 
         TestHelper::createImageAsset();
 
-        //Since the queue is processed asynchronously we need to run the worker here
-        $this->tester->runCommand('messenger:consume', ['--limit'=>2], ['pimcore_generic_data_index_queue']);
+        $this->tester->consume();
 
         $this->assertEquals(1, $indexQueueRepository->countIndexQueueEntries());
         $this->assertTrue($indexQueueRepository->dispatchableItemExists());
@@ -125,8 +124,7 @@ public function testAssetSaveProcessQueue(): void
 
         $asset = TestHelper::createImageAsset();
 
-        //Since the queue is processed asynchronously we need to run the worker here
-        $this->tester->runCommand('messenger:consume', ['--limit'=>2], ['pimcore_generic_data_index_queue']);
+        $this->tester->consume();
 
         $this->assertGreaterThan(
             0,
@@ -202,8 +200,7 @@ public function testDependenciesWithQueue(): void
         $object->setImage($asset);
         $object->save();
 
-        //Since the queue is processed asynchronously we need to run the worker here
-        $this->tester->runCommand('messenger:consume', ['--limit'=>2], ['pimcore_generic_data_index_queue']);
+        $this->tester->consume();
 
         $assetIndex = $this->searchIndexConfigService->getIndexName(self::ASSET_INDEX_NAME);
         $objectIndex = $this->searchIndexConfigService->getIndexName($object->getClassName(), true);