updated composer.lock, configured rabbitmq, added message-handler example.

Author: dmitriy

composer.lock

@@ -26,10 +26,28 @@ framework:
         failure_transport: failed
 
         transports:
+            async_priority_high:
+                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
+                options:
+                    exchange:
+                        name: high
+                    queues:
+                        messages_high: ~
+            async_priority_low:
+                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
+                options:
+                    exchange:
+                        name: low
+                    queues:
+                        messages_low: ~
+
             # Uncomment the following line to enable a transport named "amqp"
-            async: '%env(MESSENGER_TRANSPORT_DSN)%'
+            # async: '%env(MESSENGER_TRANSPORT_DSN)%'
             failed: 'doctrine://default?queue_name=failed'
 
         routing:
-            # async is whatever name you gave your transport above
-            '*': async
+            App\Message\Interfaces\MessageHighInterface: async_priority_high
+            App\Message\Interfaces\MessageLowInterface: async_priority_low
+
+            # Route your messages to the transports
+            # 'App\Message\YourMessage': async

config/packages/messenger.yaml

@@ -63,5 +63,8 @@ services:
         class: App\EventSubscriber\BlameableDecorator
         decorates: stof_doctrine_extensions.listener.blameable
 
+    App\Service\Interfaces\MessageServiceInterface:
+        class: App\Service\MessageService
+
     # add more service definitions when explicit configuration is needed
     # please note that last definitions always *replace* previous ones

config/services.yaml

@@ -0,0 +1,13 @@
+<?php
+declare(strict_types = 1);
+
+namespace App\Message\Interfaces;
+
+/**
+ * Interface MessageHighInterface
+ *
+ * @package App\Message\Interfaces
+ */
+interface MessageHighInterface
+{
+}

src/Message/Interfaces/MessageHighInterface.php

@@ -0,0 +1,13 @@
+<?php
+declare(strict_types = 1);
+
+namespace App\Message\Interfaces;
+
+/**
+ * Interface MessageLowInterface
+ *
+ * @package App\Message\Interfaces
+ */
+interface MessageLowInterface
+{
+}

src/Message/Interfaces/MessageLowInterface.php

@@ -0,0 +1,33 @@
+<?php
+declare(strict_types = 1);
+
+namespace App\Message;
+
+use App\Message\Interfaces\MessageHighInterface;
+
+/**
+ * Class TestMessage
+ * TODO: This is message example, you can delete it.
+ *
+ * @package App\Message
+ */
+class TestMessage implements MessageHighInterface
+{
+    private string $someId;
+
+    /**
+     * @param string $someId
+     */
+    public function __construct(string $someId)
+    {
+        $this->someId = $someId;
+    }
+
+    /**
+     * @return string
+     */
+    public function getSomeId(): string
+    {
+        return $this->someId;
+    }
+}

src/Message/TestMessage.php

@@ -0,0 +1,62 @@
+<?php
+declare(strict_types = 1);
+
+namespace App\MessageHandler;
+
+use App\Message\TestMessage;
+use Symfony\Component\Messenger\Handler\MessageSubscriberInterface;
+use Psr\Log\LoggerInterface;
+use Throwable;
+
+/**
+ * Class TestHandler
+ * TODO: This is handler example, you can delete it.
+ *
+ * @package App\MessageHandler
+ */
+class TestHandler implements MessageSubscriberInterface
+{
+    private LoggerInterface $logger;
+
+    /**
+     * Constructor
+     *
+     * @param LoggerInterface $logger
+     */
+    public function __construct(LoggerInterface $logger)
+    {
+        $this->logger = $logger;
+    }
+
+    /**
+     * @param TestMessage $message
+     *
+     * @throws Throwable
+     */
+    public function __invoke(TestMessage $message): void
+    {
+        $this->handleMessage($message);
+    }
+
+    /** @inheritDoc */
+    public static function getHandledMessages(): iterable
+    {
+        // handle this message on __invoke
+        yield TestMessage::class;
+
+        /*yield ...Message::class => [
+            'method' => 'handle...',
+        ];*/
+    }
+
+    /**
+     * @param TestMessage $message
+     *
+     * @throws Throwable
+     */
+    private function handleMessage(TestMessage $message): void
+    {
+        // some actions here
+        $this->logger->info('Test message processed');
+    }
+}

src/MessageHandler/TestHandler.php

@@ -0,0 +1,17 @@
+<?php
+declare(strict_types = 1);
+/**
+ * /src/Service/Interfaces/MessageServiceInterface.php
+ */
+
+namespace App\Service\Interfaces;
+
+/**
+ * Interface MessageServiceInterface
+ *
+ * @package App\Service\Interfaces
+ */
+interface MessageServiceInterface
+{
+    // TODO: implement it
+}

src/Service/Interfaces/MessageServiceInterface.php

@@ -0,0 +1,43 @@
+<?php
+declare(strict_types = 1);
+/**
+ * /src/Service/MessageService.php
+ */
+
+namespace App\Service;
+
+use App\Message\TestMessage;
+use Symfony\Component\Messenger\Envelope;
+use Symfony\Component\Messenger\MessageBusInterface;
+use App\Service\Interfaces\MessageServiceInterface;
+
+/**
+ * Class MessageService
+ *
+ * @package App\Service
+ */
+class MessageService implements MessageServiceInterface
+{
+    private MessageBusInterface $bus;
+
+    /**
+     * Constructor
+     *
+     * @param MessageBusInterface $bus
+     */
+    public function __construct(MessageBusInterface $bus)
+    {
+        $this->bus = $bus;
+    }
+
+    /**
+     * @inheritDoc
+     * TODO: This is example for creating test message, you can delete it.
+     */
+    public function sendTestMessage(string $someId): self
+    {
+        $this->bus->dispatch(new Envelope(new TestMessage($someId)));
+
+        return $this;
+    }
+}