Standardizing global function calls by using root namespace.

Adding missing class property list for Redis and Sqs classes.
nimbly · Jun 27, 2019 · 6b9c050 · 6b9c050
1 parent 8dffcb8
commit 6b9c050
Show file tree

Hide file tree

Showing 5 changed files with 15 additions and 5 deletions.
diff --git a/src/PubSub/Redis.php b/src/PubSub/Redis.php
@@ -7,6 +7,11 @@
 use Predis\PubSub\DispatcherLoop;
 use Syndicate\Message;
 
+/**
+ * 
+ * @property Client $client
+ * 
+ */
 class Redis extends PubSubAbstract
 {
     /**

diff --git a/src/Queue/MockQueue.php b/src/Queue/MockQueue.php
@@ -43,7 +43,7 @@ public function put($data, array $options = []): void
      */
     public function get(array $options = []): ?Message
     {
-        $message = array_shift($this->messages);
+        $message = \array_shift($this->messages);
 
         return new Message($this, $message, $this->deserialize($message));
     }

diff --git a/src/Queue/Queue.php b/src/Queue/Queue.php
@@ -114,8 +114,8 @@ public function getName(): string
      * @param array $params
      * @return mixed
      */
-    public function __call(string $method, array $params)
+    public function __call(string $method, array $params = [])
     {
-        return call_user_func_array([$this->client, $method], $params);
+        return \call_user_func_array([$this->client, $method], $params);
     }
 }
diff --git a/src/Queue/RedisPubSub.php b/src/Queue/RedisPubSub.php
@@ -7,6 +7,11 @@
 use Predis\PubSub\DispatcherLoop;
 use Syndicate\Message;
 
+/**
+ * 
+ * @property Client $client
+ * 
+ */
 class RedisPubSub extends Queue
 {
     /**

diff --git a/tests/MessageTest.php b/tests/MessageTest.php
@@ -19,7 +19,7 @@ public function test_get_source_message()
             "body" => '{"event": "SomeEvent", "data": {"name": "Joe Example", "email": "joe@example.com"}}'
         ];
 
-        $message = new Message(new MockQueue('TestQueue'), $sourceMessage, json_decode($sourceMessage["body"]));
+        $message = new Message(new MockQueue('TestQueue'), $sourceMessage, \json_decode($sourceMessage["body"]));
 
         $this->assertEquals($sourceMessage, $message->getSourceMessage());
     }
@@ -31,7 +31,7 @@ public function test_get_payload()
             "body" => '{"event": "SomeEvent", "data": {"name": "Joe Example", "email": "joe@example.com"}}'
         ];
 
-        $message = new Message(new MockQueue('TestQueue'), $sourceMessage, json_decode($sourceMessage["body"]));
+        $message = new Message(new MockQueue('TestQueue'), $sourceMessage, \json_decode($sourceMessage["body"]));
 
         $this->assertEquals(json_decode($sourceMessage['body']), $message->getPayload());
     }