compatibility with 0.8x

Author: ASKozienko

pkg/enqueue/Client/RouterProcessor.php

@@ -9,6 +9,11 @@
 
 final class RouterProcessor implements Processor
 {
+    /**
+     * compatibility with 0.8x
+     */
+    private const COMMAND_TOPIC_08X = '__command__';
+
     /**
      * @var DriverInterface
      */
@@ -21,6 +26,17 @@ public function __construct(DriverInterface $driver)
 
     public function process(InteropMessage $message, Context $context): Result
     {
+        // compatibility with 0.8x
+        if (self::COMMAND_TOPIC_08X === $message->getProperty(Config::TOPIC)) {
+            $clientMessage = $this->driver->createClientMessage($message);
+            $clientMessage->setProperty(Config::TOPIC, null);
+
+            $this->driver->sendToProcessor($clientMessage);
+
+            return Result::ack('Legacy 0.8x message routed to processor');
+        }
+        // compatibility with 0.8x
+
         if ($message->getProperty(Config::COMMAND)) {
             return Result::reject(sprintf(
                 'Unexpected command "%s" got. Command must not go to the router.',