Force meta, data to be array

solcloud · Nov 22, 2022 · 1ddc9fe · 1ddc9fe
1 parent d127ee7
commit 1ddc9fe
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/src/BaseConsumer.php b/src/BaseConsumer.php
@@ -136,12 +136,12 @@ protected function finishProcessing(): void
 
     /**
      * Create msg that can be published to broker
-     * @param mixed $meta
-     * @param mixed $data
+     * @param array $meta
+     * @param array $data
      * @param bool $persistent
      * @return Message
      */
-    public function createMessageHelper($meta = [], $data = [], bool $persistent = true): Message
+    public function createMessageHelper(array $meta = [], array $data = [], bool $persistent = true): Message
     {
         $properties['delivery_mode'] = ($persistent ? Message::DELIVERY_MODE_PERSISTENT : Message::DELIVERY_MODE_NON_PERSISTENT);
         if (is_numeric($meta['_priority'] ?? false)) {
@@ -156,11 +156,11 @@ public function createMessageHelper($meta = [], $data = [], bool $persistent = t
 
     /**
      * Create string for use as msg body payload
-     * @param mixed $meta
-     * @param mixed $data
+     * @param array $meta
+     * @param array $data
      * @return string
      */
-    public function createMessageBody($meta = [], $data = []): string
+    public function createMessageBody(array $meta = [], array $data = []): string
     {
         $failIfFalse = json_encode(
             [
@@ -205,7 +205,7 @@ protected function publishCurrentMsgDataTo(string $exchange = null, string $rout
             $exchange = '';
             $routingKey = $this->getConsumingQueueName();
         }
-        $this->publishMessage($this->createMessageHelper($this->meta, $this->data), $exchange, $routingKey);
+        $this->publishMessage($this->createMessageHelper((array)$this->meta, (array)$this->data), $exchange, $routingKey);
     }
 
     /**