freyo / laravel-queue-cmq

src/Queue/Driver/Queue.php

Spacing +2 added lines, -2 removed lines

@@ -215,7 +215,7 @@ 
         ];
         $n = 1;
         foreach ($messages as $message) {
-            $key = 'msgBody.'.$n;
+            $key = 'msgBody.' . $n;
             if ($this->encoding) {
                 $params[$key] = base64_encode($message->msgBody);
             } else {
@@ -325,7 +325,7 @@ 
         $params = ['queueName' => $this->queue_name];
         $n = 1;
         foreach ($receipt_handle_list as $receipt_handle) {
-            $key = 'receiptHandle.'.$n;
+            $key = 'receiptHandle.' . $n;
             $params[$key] = $receipt_handle;
             $n += 1;
         }

src/LaravelQueueCMQServiceProvider.php

Spacing +2 added lines, -2 removed lines

@@ -21,7 +21,7 @@ 
         }
         
         $this->mergeConfigFrom(
-            __DIR__.'/../config/cmq.php', 'queue.connections.cmq'
+            __DIR__ . '/../config/cmq.php', 'queue.connections.cmq'
         );
     }
 
@@ -35,7 +35,7 @@ 
         /** @var QueueManager $queue */
         $queue = $this->app['queue'];
 
-        $queue->addConnector('cmq', function () {
+        $queue->addConnector('cmq', function() {
             return new CMQConnector();
         });
     }

src/Queue/Driver/Subscription.php

Spacing +4 added lines, -4 removed lines

@@ -44,7 +44,7 @@ 
         if (is_array($subscription_meta->bindingKey) && !empty($subscription_meta->bindingKey)) {
             $n = 1;
             foreach ($subscription_meta->bindingKey as $tag) {
-                $key = 'bindingKey.'.$n;
+                $key = 'bindingKey.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }
@@ -53,7 +53,7 @@ 
         if (is_array($subscription_meta->FilterTag) && !empty($subscription_meta->FilterTag)) {
             $n = 1;
             foreach ($subscription_meta->FilterTag as $tag) {
-                $key = 'filterTag.'.$n;
+                $key = 'filterTag.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }
@@ -165,7 +165,7 @@ 
         if (is_array($subscription_meta->bindingKey) && !empty($subscription_meta->bindingKey)) {
             $n = 1;
             foreach ($subscription_meta->bindingKey as $tag) {
-                $key = 'bindingKey.'.$n;
+                $key = 'bindingKey.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }
@@ -174,7 +174,7 @@ 
         if (is_array($subscription_meta->FilterTag) && !empty($subscription_meta->FilterTag)) {
             $n = 1;
             foreach ($subscription_meta->FilterTag as $tag) {
-                $key = 'filterTag.'.$n;
+                $key = 'filterTag.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }

src/Queue/Driver/CMQHttp.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
     {
         $this->connection_timeout = $connection_timeout;
         $this->keep_alive = $keep_alive;
-        $this->host = $host.'/v2/index.php';
+        $this->host = $host . '/v2/index.php';
         $this->curl = null;
     }
 
@@ -55,7 +55,7 @@ 
             curl_setopt($this->curl, CURLOPT_POST, 1);
             curl_setopt($this->curl, CURLOPT_POSTFIELDS, $req_inter->data);
         } else {
-            $url .= $req_inter->uri.'?'.$req_inter->data;
+            $url .= $req_inter->uri . '?' . $req_inter->data;
         }
 
         if (isset($req_inter->header)) {

src/Queue/CMQQueue.php

Spacing +7 added lines, -7 removed lines

@@ -75,7 +75,7 @@ 
      */
     public function isPlain()
     {
-        return (bool) Arr::get($this->plainOptions, 'enable');
+        return (bool)Arr::get($this->plainOptions, 'enable');
     }
 
     /**
@@ -97,7 +97,7 @@ 
     {
         $attributes = $this->getQueue($queue)->get_attributes();
 
-        return (int) $attributes->activeMsgNum;
+        return (int)$attributes->activeMsgNum;
     }
 
     /**
@@ -147,22 +147,22 @@ 
             switch ($this->topicOptions['filter']) {
                 case self::CMQ_TOPIC_TAG_FILTER_NAME:
                     return retry(Arr::get($this->topicOptions, 'retries', 3),
-                        function () use ($driver, $message, $queue) {
+                        function() use ($driver, $message, $queue) {
                             return $driver->publish_message($message->msgBody, explode(',', $queue), null);
                         });
                 case self::CMQ_TOPIC_ROUTING_FILTER_NAME:
                     return retry(Arr::get($this->topicOptions, 'retries', 3),
-                        function () use ($driver, $message, $queue) {
+                        function() use ($driver, $message, $queue) {
                             $driver->publish_message($message->msgBody, [], $queue);
                         });
                 default:
                     throw new \InvalidArgumentException(
-                        'Invalid CMQ topic filter: '.$this->topicOptions['filter']
+                        'Invalid CMQ topic filter: ' . $this->topicOptions['filter']
                     );
             }
         }
 
-        return retry(Arr::get($this->queueOptions, 'retries', 3), function () use ($driver, $message, $options) {
+        return retry(Arr::get($this->queueOptions, 'retries', 3), function() use ($driver, $message, $options) {
             return $driver->send_message($message, Arr::get($options, 'delay', 0));
         });
     }
@@ -209,7 +209,7 @@ 
             $queue = $this->getQueue($queue);
             $message = $queue->receive_message($this->queueOptions['polling_wait_seconds']);
         } catch (CMQServerException $e) {
-            if (self::CMQ_QUEUE_NO_MESSAGE_CODE === (int) $e->getCode()) { // ignore no message
+            if (self::CMQ_QUEUE_NO_MESSAGE_CODE === (int)$e->getCode()) { // ignore no message
                 return;
             }