Implement SubscriberInterface for listeners

Author: ZhukV

src/Listener/OutputListener.php

@@ -16,13 +16,24 @@
 use FiveLab\Component\Amqp\Consumer\ConsumerStoppedReason;
 use FiveLab\Component\Amqp\Event\ConsumerStoppedEvent;
 use FiveLab\Component\Amqp\Event\ReceiveMessageEvent;
+use Symfony\Component\Console\ConsoleEvents;
 use Symfony\Component\Console\Event\ConsoleCommandEvent;
 use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
 
-class OutputListener
+class OutputListener implements EventSubscriberInterface
 {
     private ?OutputInterface $output = null;
 
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            ConsoleEvents::COMMAND      => ['onConsoleCommand', 0],
+            ConsumerStoppedEvent::class => ['onConsumerStopped', 0],
+            ReceiveMessageEvent::class  => ['onReceiveMessage', 0],
+        ];
+    }
+
     public function onConsoleCommand(ConsoleCommandEvent $event): void
     {
         $this->output = $event->getOutput();

src/Listener/StopAfterNExecutesListener.php

@@ -27,6 +27,13 @@ public function __construct(private readonly EventDispatcherInterface $eventDisp
     {
     }
 
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            ProcessedMessageEvent::class => ['onProcessedMessage', -1024],
+        ];
+    }
+
     public function onProcessedMessage(ProcessedMessageEvent $event): void
     {
         $this->executesCounter++;
@@ -39,11 +46,4 @@ public function onProcessedMessage(ProcessedMessageEvent $event): void
             $event->consumer->stop();
         }
     }
-
-    public static function getSubscribedEvents(): array
-    {
-        return [
-            ProcessedMessageEvent::class => ['onProcessedMessage', 0],
-        ];
-    }
 }

tests/Unit/Listener/OutputListenerTest.php

@@ -40,6 +40,16 @@ protected function setUp(): void
         $this->listener = new OutputListener();
     }
 
+    #[Test]
+    public function shouldSuccessGetListeners(): void
+    {
+        self::assertEquals([
+            'console.command'           => ['onConsoleCommand', 0],
+            ConsumerStoppedEvent::class => ['onConsumerStopped', 0],
+            ReceiveMessageEvent::class  => ['onReceiveMessage', 0],
+        ], OutputListener::getSubscribedEvents());
+    }
+
     #[Test]
     #[TestWith([ConsumerStoppedReason::Timeout, '<comment>Receive consumer timeout exceed error.</comment>'])]
     #[TestWith([ConsumerStoppedReason::StopConsuming, '<comment>Stop consuming.</comment>'])]

tests/Unit/Listener/StopAfterNExecutesListenerTest.php

@@ -23,6 +23,14 @@
 
 class StopAfterNExecutesListenerTest extends TestCase
 {
+    #[Test]
+    public function shouldSuccessGetListeners(): void
+    {
+        self::assertEquals([
+            ProcessedMessageEvent::class => ['onProcessedMessage', -1024],
+        ], StopAfterNExecutesListener::getSubscribedEvents());
+    }
+
     #[Test]
     public function shouldSuccessStopAfterReachedLimit(): void
     {