Fix events compatibility

Author: andrewmy

DependencyInjection/AsyncEventsPass.php

@@ -6,6 +6,7 @@
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\EventDispatcher\DependencyInjection\RegisterListenersPass;
 use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+use Symfony\Component\HttpKernel\Kernel;
 
 class AsyncEventsPass implements CompilerPassInterface
 {
@@ -21,6 +22,9 @@ public function process(ContainerBuilder $container): void
 
         $defaultClient = $container->getParameter('enqueue.default_client');
 
+        // TODO: Remove when dropping Symfony < 5.3
+        $useLegacyDispatcherConfig = (Kernel::VERSION_ID < 50300);
+
         $registeredToEvent = [];
         foreach ($container->findTaggedServiceIds('kernel.event_listener') as $serviceId => $tagAttributes) {
             foreach ($tagAttributes as $tagAttribute) {
@@ -32,8 +36,10 @@ public function process(ContainerBuilder $container): void
 
                 $service = $container->getDefinition($serviceId);
 
-                $service->clearTag('kernel.event_listener');
-                $service->addTag('enqueue.async_event_listener', $tagAttribute);
+                if ($useLegacyDispatcherConfig) {
+                    $service->clearTag('kernel.event_listener');
+                    $service->addTag('enqueue.async_event_listener', $tagAttribute);
+                }
 
                 if (false == isset($registeredToEvent[$event])) {
                     $container->getDefinition('enqueue.events.async_listener')
@@ -43,6 +49,16 @@ public function process(ContainerBuilder $container): void
                         ])
                     ;
 
+                    if (!$useLegacyDispatcherConfig) {
+                        $container->getDefinition('enqueue.events.async_listener')
+                            ->addTag('kernel.event_listener', [
+                                'event' => $event,
+                                'method' => 'onEvent',
+                                'dispatcher' => 'enqueue.events.event_dispatcher',
+                            ])
+                        ;
+                    }
+
                     $container->getDefinition('enqueue.events.async_processor')
                         ->addTag('enqueue.processor', [
                             'topic' => 'event.'.$event,
@@ -62,8 +78,11 @@ public function process(ContainerBuilder $container): void
                 }
 
                 $service = $container->getDefinition($serviceId);
-                $service->clearTag('kernel.event_subscriber');
-                $service->addTag('enqueue.async_event_subscriber', $tagAttribute);
+
+                if ($useLegacyDispatcherConfig) {
+                    $service->clearTag('kernel.event_subscriber');
+                    $service->addTag('enqueue.async_event_subscriber', $tagAttribute);
+                }
 
                 /** @var EventSubscriberInterface $serviceClass */
                 $serviceClass = $service->getClass();
@@ -77,6 +96,16 @@ public function process(ContainerBuilder $container): void
                             ])
                         ;
 
+                        if (!$useLegacyDispatcherConfig) {
+                            $container->getDefinition('enqueue.events.async_listener')
+                                ->addTag('kernel.event_listener', [
+                                    'event' => $event,
+                                    'method' => 'onEvent',
+                                    'dispatcher' => 'enqueue.events.event_dispatcher',
+                                ])
+                            ;
+                        }
+
                         $container->getDefinition('enqueue.events.async_processor')
                             ->addTag('enqueue.processor', [
                                 'topicName' => 'event.'.$event,
@@ -90,11 +119,13 @@ public function process(ContainerBuilder $container): void
             }
         }
 
-        $registerListenersPass = new RegisterListenersPass(
-            'enqueue.events.event_dispatcher',
-            'enqueue.async_event_listener',
-            'enqueue.async_event_subscriber'
-        );
-        $registerListenersPass->process($container);
+        if ($useLegacyDispatcherConfig) {
+            $registerListenersPass = new RegisterListenersPass(
+                'enqueue.events.event_dispatcher',
+                'enqueue.async_event_listener',
+                'enqueue.async_event_subscriber'
+            );
+            $registerListenersPass->process($container);
+        }
     }
 }