[client] Add ability to preapre message, or use no JSON format.

pkg/enqueue/Client/ChainExtension.php

@@ -17,23 +17,33 @@ public function __construct(array $extensions)
         $this->extensions = $extensions;
     }
 
+    /**
+     * @param OnPrepareMessage $context
+     */
+    public function onPrepareMessage(OnPrepareMessage $context)
+    {
+        foreach ($this->extensions as $extension) {
+            $extension->onPrepareMessage($context);
+        }
+    }
+
     /**
      * {@inheritdoc}
      */
-    public function onPreSend($topic, Message $message)
+    public function onSend(OnSend $context)
     {
         foreach ($this->extensions as $extension) {
-            $extension->onPreSend($topic, $message);
+            $extension->onSend($context);
         }
     }
 
     /**
      * {@inheritdoc}
      */
-    public function onPostSend($topic, Message $message)
+    public function onPostSend(OnPostSend $context)
     {
         foreach ($this->extensions as $extension) {
-            $extension->onPostSend($topic, $message);
+            $extension->onPostSend($context);
         }
     }
 }

pkg/enqueue/Client/ConsumptionExtension/ExclusiveCommandExtension.php

@@ -3,15 +3,17 @@
 namespace Enqueue\Client\ConsumptionExtension;
 
 use Enqueue\Client\Config;
+use Enqueue\Client\EmptyExtensionTrait as ClientEmptyExtensionTrait;
 use Enqueue\Client\ExtensionInterface as ClientExtensionInterface;
-use Enqueue\Client\Message;
+use Enqueue\Client\OnSend;
 use Enqueue\Consumption\Context;
-use Enqueue\Consumption\EmptyExtensionTrait;
+use Enqueue\Consumption\EmptyExtensionTrait as ConsumptionEmptyExtensionTrait;
 use Enqueue\Consumption\ExtensionInterface as ConsumptionExtensionInterface;
 
 class ExclusiveCommandExtension implements ConsumptionExtensionInterface, ClientExtensionInterface
 {
-    use EmptyExtensionTrait;
+    use ConsumptionEmptyExtensionTrait;
+    use ClientEmptyExtensionTrait;
 
     /**
      * @var string[]
@@ -63,23 +65,18 @@ public function onPreReceived(Context $context)
     /**
      * {@inheritdoc}
      */
-    public function onPreSend($topic, Message $message)
+    public function onSend(OnSend $context)
     {
-        if (Config::COMMAND_TOPIC != $topic) {
+        if (false == $context->getCommand()) {
             return;
         }
 
+        $message = $context->getMessage();
+
         $commandName = $message->getProperty(Config::PARAMETER_COMMAND_NAME);
         if (array_key_exists($commandName, $this->processorNameToQueueNameMap)) {
             $message->setProperty(Config::PARAMETER_PROCESSOR_NAME, $commandName);
             $message->setProperty(Config::PARAMETER_PROCESSOR_QUEUE_NAME, $this->processorNameToQueueNameMap[$commandName]);
         }
     }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function onPostSend($topic, Message $message)
-    {
-    }
 }

pkg/enqueue/Client/EmptyExtensionTrait.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace Enqueue\Client;
+
+trait EmptyExtensionTrait
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function onPrepareMessage(OnPrepareMessage $context)
+    {
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function onSend(OnSend $context)
+    {
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function onPostSend(OnPostSend $context)
+    {
+    }
+}

pkg/enqueue/Client/ExtensionInterface.php

@@ -5,18 +5,17 @@
 interface ExtensionInterface
 {
     /**
-     * @param string  $topic
-     * @param Message $message
-     *
-     * @return
+     * @param OnPrepareMessage $context
      */
-    public function onPreSend($topic, Message $message);
+    public function onPrepareMessage(OnPrepareMessage $context);
 
     /**
-     * @param string  $topic
-     * @param Message $message
-     *
-     * @return
+     * @param OnSend $context
      */
-    public function onPostSend($topic, Message $message);
+    public function onSend(OnSend $context);
+
+    /**
+     * @param OnPostSend $context
+     */
+    public function onPostSend(OnPostSend $context);
 }

pkg/enqueue/Client/OnPostSend.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace Enqueue\Client;
+
+class OnPostSend
+{
+    /**
+     * @var Message
+     */
+    private $message;
+
+    /**
+     * @var string|null
+     */
+    private $topic;
+
+    /**
+     * @var string|null
+     */
+    private $command;
+
+    public function __construct(Message $message, $topic, $command)
+    {
+        $this->message = $message;
+        $this->topic = $topic;
+        $this->command = $command;
+    }
+
+    /**
+     * @return Message
+     */
+    public function getMessage()
+    {
+        return $this->message;
+    }
+
+    /**
+     * @return null|string
+     */
+    public function getTopic()
+    {
+        return $this->topic;
+    }
+
+    /**
+     * @return null|string
+     */
+    public function getCommand()
+    {
+        return $this->command;
+    }
+}

pkg/enqueue/Client/OnPrepareMessage.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace Enqueue\Client;
+
+class OnPrepareMessage
+{
+    /**
+     * @var string|array|Message|\JsonSerializable
+     */
+    private $message;
+
+    /**
+     * @var string|null
+     */
+    private $topic;
+
+    /**
+     * @var string|null
+     */
+    private $command;
+
+    public function __construct($message, $topic, $command)
+    {
+        $this->message = $message;
+        $this->topic = $topic;
+        $this->command = $command;
+    }
+
+    /**
+     * @return array|Message|\JsonSerializable|string
+     */
+    public function getMessage()
+    {
+        return $this->message;
+    }
+
+    /**
+     * @param array|Message|\JsonSerializable|string $message
+     */
+    public function setMessage($message)
+    {
+        $this->message = $message;
+    }
+
+    /**
+     * @return null|string
+     */
+    public function getTopic()
+    {
+        return $this->topic;
+    }
+
+    /**
+     * @return null|string
+     */
+    public function getCommand()
+    {
+        return $this->command;
+    }
+}

pkg/enqueue/Client/OnSend.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace Enqueue\Client;
+
+class OnSend
+{
+    /**
+     * @var Message
+     */
+    private $message;
+
+    /**
+     * @var string|null
+     */
+    private $topic;
+
+    /**
+     * @var string|null
+     */
+    private $command;
+
+    public function __construct(Message $message, $topic, $command)
+    {
+        $this->message = $message;
+        $this->topic = $topic;
+        $this->command = $command;
+    }
+
+    /**
+     * @return Message
+     */
+    public function getMessage()
+    {
+        return $this->message;
+    }
+
+    /**
+     * @return null|string
+     */
+    public function getTopic()
+    {
+        return $this->topic;
+    }
+
+    /**
+     * @return null|string
+     */
+    public function getCommand()
+    {
+        return $this->command;
+    }
+}