compatibility with 0.9x

Author: ASKozienko

pkg/enqueue/Client/Producer.php

@@ -8,6 +8,12 @@
 
 class Producer implements ProducerInterface
 {
+    /**
+     * compatibility with 0.9x
+     */
+    const TOPIC_09X = 'enqueue.topic';
+    const COMMAND_09X = 'enqueue.command';
+
     /**
      * @var DriverInterface
      */
@@ -54,6 +60,7 @@ public function sendEvent($topic, $message)
         $this->prepareBody($message);
 
         $message->setProperty(Config::PARAMETER_TOPIC_NAME, $topic);
+        $message->setProperty(self::TOPIC_09X, $topic);
 
         if (!$message->getMessageId()) {
             $message->setMessageId(UUID::generate());
@@ -119,6 +126,7 @@ public function sendCommand($command, $message, $needReply = false)
 
         $message->setProperty(Config::PARAMETER_TOPIC_NAME, Config::COMMAND_TOPIC);
         $message->setProperty(Config::PARAMETER_COMMAND_NAME, $command);
+        $message->setProperty(self::COMMAND_09X, $command);
         $message->setScope(Message::SCOPE_APP);
 
         $this->sendEvent(Config::COMMAND_TOPIC, $message);