freyo / laravel-queue-cmq

src/Queue/Driver/Account.php

Spacing +2 added lines, -2 removed lines

@@ -122,7 +122,7 @@ 
         if ($offset == '') {
             $next_offset = count($ret_pkg['queueList']);
         } else {
-            $next_offset = (int) $offset + count($ret_pkg['queueList']);
+            $next_offset = (int)$offset + count($ret_pkg['queueList']);
         }
         if ($next_offset >= $ret_pkg['totalCount']) {
             $next_offset = '';
@@ -164,7 +164,7 @@ 
         if ($offset == '') {
             $next_offset = count($resp['topicList']);
         } else {
-            $next_offset = (int) $offset + count($resp['topicList']);
+            $next_offset = (int)$offset + count($resp['topicList']);
         }
         if ($next_offset >= $resp['totalCount']) {
             $next_offset = '';

src/Queue/Driver/CMQClient.php

Spacing +3 added lines, -3 removed lines

@@ -30,7 +30,7 @@ 
         } elseif (strpos($host, 'https://') === 0) {
             $_host = substr($host, 8, strlen($host) - 8);
         } else {
-            throw new CMQClientParameterException('Only support http(s) prototol. Invalid endpoint:'.$host);
+            throw new CMQClientParameterException('Only support http(s) prototol. Invalid endpoint:' . $host);
         }
         if ($_host[strlen($_host) - 1] == '/') {
             $this->host = substr($_host, 0, strlen($_host) - 1);
@@ -46,7 +46,7 @@ 
         } elseif ($sign_method == 'sha256') {
             $this->sign_method = 'HmacSHA256';
         } else {
-            throw new CMQClientParameterException('Only support sign method HmasSHA256 or HmacSHA1 . Invalid sign method:'.$sign_method);
+            throw new CMQClientParameterException('Only support sign method HmasSHA256 or HmacSHA1 . Invalid sign method:' . $sign_method);
         }
     }
 
@@ -80,7 +80,7 @@ 
         $iTimeout = 0;
 
         if (array_key_exists('UserpollingWaitSeconds', $params)) {
-            $iTimeout = (int) $params['UserpollingWaitSeconds'];
+            $iTimeout = (int)$params['UserpollingWaitSeconds'];
         }
         // send request
         $resp_inter = $this->http->send_request($req_inter, $iTimeout);

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/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

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