Merge pull request #8 from SykesCottages/add-extra-option

Expose the raw message for sqs
SykesCottages · Sep 6, 2019 · f7d1e65 · f7d1e65
2 parents c552ec4 + c2974ca
commit f7d1e65
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 4 deletions.
diff --git a/src/Message/Contract/Message.php b/src/Message/Contract/Message.php
@@ -6,5 +6,5 @@
 
 interface Message
 {
-    public function getBody(): array;
+    public function getBody(): ?array;
 }
diff --git a/src/Message/RabbitMQMessage.php b/src/Message/RabbitMQMessage.php
@@ -20,7 +20,7 @@ public function __construct(AMQPMessage $message)
         $this->message = $message;
     }
 
-    public function getBody(): array
+    public function getBody(): ?array
     {
         return json_decode($this->message->getBody(), true);
     }

diff --git a/src/Message/SQSMessage.php b/src/Message/SQSMessage.php
@@ -18,13 +18,18 @@ public function __construct(array $message)
         $this->message = $message;
     }
 
-    public function getBody(): array
+    public function getBody() : ?array
     {
         return json_decode($this->message['Body'], true);
     }
 
-    public function getReceiptHandle(): string
+    public function getReceiptHandle() : string
     {
         return $this->message['ReceiptHandle'];
     }
+
+    public function getRawMessage() : array
+    {
+        return $this->message;
+    }
 }