freyo / laravel-queue-cmq

src/Queue/CMQQueue.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
     {
         $attributes = $this->getQueue($queue)->get_attributes();
 
-        return (int) $attributes->activeMsgNum;
+        return (int)$attributes->activeMsgNum;
     }
 
     /**

src/Queue/Driver/CMQExceptionBase.php

Indentation +2 added lines, -2 removed lines

@@ -37,8 +37,8 @@
     public function get_info()
     {
         $info = array("code"    => $this->code,
-                      "data"    => json_encode($this->data),
-                      "message" => $this->message);
+                        "data"    => json_encode($this->data),
+                        "message" => $this->message);
         return json_encode($info);
     }
 }

src/Queue/Driver/RequestInternal.php

Indentation +3 added lines, -3 removed lines

@@ -23,9 +23,9 @@
     public function __toString()
     {
         $info = array("method" => $this->method,
-                      "uri"    => $this->uri,
-                      "header" => json_encode($this->header),
-                      "data"   => $this->data);
+                        "uri"    => $this->uri,
+                        "header" => json_encode($this->header),
+                        "data"   => $this->data);
         return json_encode($info);
     }
 }

src/Queue/Driver/CMQServerNetworkException.php

Indentation +2 added lines, -2 removed lines

@@ -23,8 +23,8 @@
     public function __toString()
     {
         $info = array("status" => $this->status,
-                      "header" => json_encode($this->header),
-                      "data"   => $this->data);
+                        "header" => json_encode($this->header),
+                        "data"   => $this->data);
 
         return "CMQServerNetworkException  " . json_encode($info);
     }

src/Queue/Driver/CMQHttp.php

Braces +3 added lines, -2 removed lines

@@ -41,8 +41,9 @@
         if (!$this->keep_alive) {
             $this->curl = curl_init();
         } else {
-            if ($this->curl == NULL)
-                $this->curl = curl_init();
+            if ($this->curl == NULL) {
+                            $this->curl = curl_init();
+            }
         }
 
         if ($this->curl == NULL) {

src/Queue/Driver/Queue.php

Spacing +3 added lines, -3 removed lines

@@ -186,7 +186,7 @@ 
         } else {
             $msgBody = $message->msgBody;
         }
-        $params        = array(
+        $params = array(
             'queueName'    => $this->queue_name,
             'msgBody'      => $msgBody,
             'delaySeconds' => $delayTime
@@ -212,7 +212,7 @@ 
             'queueName'    => $this->queue_name,
             'delaySeconds' => $delayTime
         );
-        $n      = 1;
+        $n = 1;
         foreach ($messages as $message) {
             $key = 'msgBody.' . $n;
             if ($this->encoding) {
@@ -324,7 +324,7 @@ 
         foreach ($receipt_handle_list as $receipt_handle) {
             $key          = 'receiptHandle.' . $n;
             $params[$key] = $receipt_handle;
-            $n            += 1;
+            $n += 1;
         }
         $this->cmq_client->batch_delete_message($params);
     }

src/Queue/Driver/QueueMeta.php

Indentation +13 added lines, -13 removed lines

@@ -59,19 +59,19 @@
     public function __toString()
     {
         $info = array("visibilityTimeout"   => $this->visibilityTimeout,
-                      "maxMsgHeapNum"       => $this->maxMsgHeapNum,
-                      "maxMsgSize"          => $this->maxMsgSize,
-                      "msgRetentionSeconds" => $this->msgRetentionSeconds,
-                      "pollingWaitSeconds"  => $this->pollingWaitSeconds,
-                      "activeMsgNum"        => $this->activeMsgNum,
-                      "inactiveMsgNum"      => $this->inactiveMsgNum,
-                      "createTime"          => date("Y-m-d H:i:s", $this->createTime),
-                      "lastModifyTime"      => date("Y-m-d H:i:s", $this->lastModifyTime),
-                      "QueueName"           => $this->queueName,
-                      "rewindSeconds"       => $this->rewindSeconds,
-                      "rewindmsgNum"        => $this->rewindmsgNum,
-                      "minMsgTime"          => $this->minMsgTime,
-                      "delayMsgNum"         => $this->delayMsgNum);
+                        "maxMsgHeapNum"       => $this->maxMsgHeapNum,
+                        "maxMsgSize"          => $this->maxMsgSize,
+                        "msgRetentionSeconds" => $this->msgRetentionSeconds,
+                        "pollingWaitSeconds"  => $this->pollingWaitSeconds,
+                        "activeMsgNum"        => $this->activeMsgNum,
+                        "inactiveMsgNum"      => $this->inactiveMsgNum,
+                        "createTime"          => date("Y-m-d H:i:s", $this->createTime),
+                        "lastModifyTime"      => date("Y-m-d H:i:s", $this->lastModifyTime),
+                        "QueueName"           => $this->queueName,
+                        "rewindSeconds"       => $this->rewindSeconds,
+                        "rewindmsgNum"        => $this->rewindmsgNum,
+                        "minMsgTime"          => $this->minMsgTime,
+                        "delayMsgNum"         => $this->delayMsgNum);
         return json_encode($info);
     }
 }

src/Queue/Driver/Message.php

Indentation +6 added lines, -6 removed lines

@@ -39,12 +39,12 @@
     public function __toString()
     {
         $info = array("msgBody"          => $this->msgBody,
-                      "msgId"            => $this->msgId,
-                      "enqueueTime"      => date("Y-m-d H:i:s", $this->enqueueTime),
-                      "nextVisibleTime"  => date("Y-m-d H:i:s", $this->nextVisibleTime),
-                      "firstDequeueTime" => date("Y-m-d H:i:s", $this->firstDequeueTime),
-                      "dequeueCount"     => $this->dequeueCount,
-                      "receiptHandle"    => $this->receiptHandle);
+                        "msgId"            => $this->msgId,
+                        "enqueueTime"      => date("Y-m-d H:i:s", $this->enqueueTime),
+                        "nextVisibleTime"  => date("Y-m-d H:i:s", $this->nextVisibleTime),
+                        "firstDequeueTime" => date("Y-m-d H:i:s", $this->firstDequeueTime),
+                        "dequeueCount"     => $this->dequeueCount,
+                        "receiptHandle"    => $this->receiptHandle);
         return json_encode($info);
     }
 }

src/Queue/Driver/ResponseInternal.php

Indentation +2 added lines, -2 removed lines

@@ -22,8 +22,8 @@
     public function __toString()
     {
         $info = array("status" => $this->status,
-                      "header" => json_encode($this->header),
-                      "data"   => $this->data);
+                        "header" => json_encode($this->header),
+                        "data"   => $this->data);
         return json_encode($info);
     }
 }