[psr] Introduce MessageProcessor interface (moved from consumption).

It would allow to decouple consumption code from consumption component.
It must depends on psr queue only.

Author: makasim

pkg/enqueue/Consumption/MessageProcessorInterface.php

@@ -1,16 +1,11 @@
 <?php
 namespace Enqueue\Consumption;
 
-use Enqueue\Psr\Context as PsrContext;
-use Enqueue\Psr\Message as PsrMessage;
+use Enqueue\Psr\MessageProcessor;
 
-interface MessageProcessorInterface
+/**
+ * @deprecated
+ */
+interface MessageProcessorInterface extends MessageProcessor
 {
-    /**
-     * @param PsrMessage $message
-     * @param PsrContext $context
-     *
-     * @return string
-     */
-    public function process(PsrMessage $message, PsrContext $context);
 }

pkg/enqueue/Consumption/Result.php

@@ -1,54 +1,33 @@
 <?php
 namespace Enqueue\Consumption;
 
-use Enqueue\Psr\Message;
+use Enqueue\Psr\Message as PsrMessage;
+use Enqueue\Psr\Result as PsrResult;
 
-class Result
+class Result extends PsrResult
 {
-    /**
-     * Use this constant when the message is processed successfully and the message could be removed from the queue.
-     */
-    const ACK = 'enqueue.message_queue.consumption.ack';
-
-    /**
-     * Use this constant when the message is not valid or could not be processed
-     * The message is removed from the queue.
-     */
-    const REJECT = 'enqueue.message_queue.consumption.reject';
-
-    /**
-     * Use this constant when the message is not valid or could not be processed right now but we can try again later
-     * The original message is removed from the queue but a copy is publsihed to the queue again.
-     */
-    const REQUEUE = 'enqueue.message_queue.consumption.requeue';
-
-    /**
-     * @var string
-     */
-    private $status;
-
     /**
      * @var string
      */
     private $reason;
 
     /**
-     * @var Message|null
+     * @var PsrMessage|null
      */
     private $reply;
 
     /**
-     * @return Message|null
+     * @return PsrMessage|null
      */
     public function getReply()
     {
         return $this->reply;
     }
 
     /**
-     * @param Message|null $reply
+     * @param PsrMessage|null $reply
      */
-    public function setReply(Message $reply = null)
+    public function setReply(PsrMessage $reply = null)
     {
         $this->reply = $reply;
     }
@@ -59,16 +38,9 @@ public function setReply(Message $reply = null)
      */
     public function __construct($status, $reason = '')
     {
-        $this->status = (string) $status;
-        $this->reason = (string) $reason;
-    }
+        parent::__construct($status);
 
-    /**
-     * @return string
-     */
-    public function getStatus()
-    {
-        return $this->status;
+        $this->reason = (string) $reason;
     }
 
     /**
@@ -110,24 +82,16 @@ public static function requeue($reason = '')
     }
 
     /**
-     * @param Message     $replyMessage
+     * @param PsrMessage  $replyMessage
      * @param string|null $reason
      *
      * @return Result
      */
-    public static function reply(Message $replyMessage, $reason = '')
+    public static function reply(PsrMessage $replyMessage, $reason = '')
     {
         $result = static::ack($reason);
         $result->setReply($replyMessage);
 
         return $result;
     }
-
-    /**
-     * @return string
-     */
-    public function __toString()
-    {
-        return $this->status;
-    }
 }

pkg/psr-queue/MessageProcessor.php

@@ -0,0 +1,15 @@
+<?php
+namespace Enqueue\Psr;
+
+interface MessageProcessor
+{
+    /**
+     * The method has to return eitherResult::ACK, Result::REJECT, Result::REQUEUE string or instance of Result.
+     *
+     * @param Message $message
+     * @param Context $context
+     *
+     * @return string|Result
+     */
+    public function process(Message $message, Context $context);
+}

pkg/psr-queue/Result.php

@@ -0,0 +1,51 @@
+<?php
+namespace Enqueue\Psr;
+
+class Result
+{
+    /**
+     * Use this constant when the message is processed successfully and the message could be removed from the queue.
+     */
+    const ACK = 'enqueue.message_queue.consumption.ack';
+
+    /**
+     * Use this constant when the message is not valid or could not be processed
+     * The message is removed from the queue.
+     */
+    const REJECT = 'enqueue.message_queue.consumption.reject';
+
+    /**
+     * Use this constant when the message is not valid or could not be processed right now but we can try again later
+     * The original message is removed from the queue but a copy is publsihed to the queue again.
+     */
+    const REQUEUE = 'enqueue.message_queue.consumption.requeue';
+
+    /**
+     * @var string
+     */
+    private $status;
+
+    /**
+     * @param string $status
+     */
+    public function __construct($status)
+    {
+        $this->status = (string) $status;
+    }
+
+    /**
+     * @return string
+     */
+    public function getStatus()
+    {
+        return $this->status;
+    }
+
+    /**
+     * @return string
+     */
+    public function __toString()
+    {
+        return $this->status;
+    }
+}