snsqs fix typo

php-enqueue · Feb 20, 2019 · 42edb58 · 42edb58
1 parent 6c11421
commit 42edb58
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/SnsQsConnectionFactory.php b/SnsQsConnectionFactory.php
@@ -71,9 +71,9 @@ public function __construct($config = 'snsqs:')
      */
     public function createContext(): Context
     {
-        return new SnsQsContext(function() {
+        return new SnsQsContext(function () {
             return (new SnsConnectionFactory($this->snsConfig))->createContext();
-        }, function() {
+        }, function () {
             return (new SqsConnectionFactory($this->sqsConfig))->createContext();
         });
     }
@@ -96,7 +96,7 @@ private function parseOptions(array $options): void
     {
         // set default options
         foreach ($options as $key => $value) {
-            if (false === in_array(substr($key, 0, 4), ['sns_', 'sqs_'])) {
+            if (false === in_array(substr($key, 0, 4), ['sns_', 'sqs_'], true)) {
                 $this->snsConfig[$key] = $value;
                 $this->sqsConfig[$key] = $value;
             }

diff --git a/SnsQsConsumer.php b/SnsQsConsumer.php
@@ -86,10 +86,10 @@ private function convertMessage(SqsMessage $sqsMessage): SnsQsMessage
 
         $body = $sqsMessage->getBody();
 
-        if (isset($body[0]) && $body[0] === '{') {
+        if (isset($body[0]) && '{' === $body[0]) {
             $data = json_decode($sqsMessage->getBody(), true);
 
-            if (isset($data['TopicArn']) && isset($data['Type']) && $data['Type'] === 'Notification') {
+            if (isset($data['TopicArn']) && isset($data['Type']) && 'Notification' === $data['Type']) {
                 // SNS message conversion
                 if (isset($data['Message'])) {
                     $message->setBody((string) $data['Message']);

diff --git a/SnsQsProducer.php b/SnsQsProducer.php
@@ -43,7 +43,7 @@ public function __construct(SnsContext $snsContext, SqsContext $sqsContext)
     }
 
     /**
-     * @param SnsQsTopic $destination
+     * @param SnsQsTopic   $destination
      * @param SnsQsMessage $message
      */
     public function send(Destination $destination, Message $message): void

diff --git a/Tests/Spec/SnsQsSendToAndReceiveNoWaitFromQueueTest.php b/Tests/Spec/SnsQsSendToAndReceiveNoWaitFromQueueTest.php
@@ -10,7 +10,7 @@
  * @group functional
  * @retry 5
  */
-class SqsQsSendToAndReceiveNoWaitFromQueueTest extends SendToAndReceiveNoWaitFromQueueSpec
+class SnsQsSendToAndReceiveNoWaitFromQueueTest extends SendToAndReceiveNoWaitFromQueueSpec
 {
     use RetryTrait;
     use SnsQsFactoryTrait;