Add Symfony scheduler for automatic queue triggering once a minute

composer.json

@@ -21,7 +21,8 @@
     "pimcore/enterprise-subscription-tools": "^1.3",
     "pimcore/pimcore": "^11.0",
     "opensearch-project/opensearch-php": "^2.2.0",
-    "doctrine/orm": "^2.17.2"
+    "doctrine/orm": "^2.17.2",
+    "symfony/scheduler": "^6.3|^7.0"
   },
   "require-dev": {
     "roave/security-advisories": "dev-latest",

config/services.yaml

@@ -23,6 +23,7 @@ services:
         tags: [ { name: messenger.message_handler, bus: messenger.bus.pimcore-generic-data-index } ]
 
     Pimcore\Bundle\GenericDataIndexBundle\Service\TimeService: ~
+    Pimcore\Bundle\GenericDataIndexBundle\Scheduler\GenericDataIndexScheduleProvider: ~
     Pimcore\Bundle\GenericDataIndexBundle\Installer:
         public: true
         arguments:

src/Scheduler/GenericDataIndexScheduleProvider.php

@@ -0,0 +1,21 @@
+<?php
+declare(strict_types=1);
+
+namespace Pimcore\Bundle\GenericDataIndexBundle\Scheduler;
+
+use Pimcore\Bundle\GenericDataIndexBundle\Message\DispatchQueueMessagesMessage;
+use Symfony\Component\Scheduler\Attribute\AsSchedule;
+use Symfony\Component\Scheduler\RecurringMessage;
+use Symfony\Component\Scheduler\Schedule;
+use Symfony\Component\Scheduler\ScheduleProviderInterface;
+
+#[AsSchedule('generic_data_index')]
+class GenericDataIndexScheduleProvider implements ScheduleProviderInterface
+{
+    public function getSchedule(): Schedule
+    {
+        return (new Schedule())->add(
+            RecurringMessage::every('1 minute', new DispatchQueueMessagesMessage())
+        );
+    }
+}