freyo / laravel-queue-cmq

src/Queue/Driver/RequestInternal.php

Indentation +3 added lines, -3 removed lines

@@ -23,9 +23,9 @@
     public function __toString()
     {
         $info = ['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/Topic.php

Indentation +2 added lines, -2 removed lines

@@ -238,7 +238,7 @@
         }
 
         return ['totalCoult'            => $resp['totalCount'],
-                     'subscriptionList' => $resp['subscriptionList'],
-                     'next_offset'      => $next_offset, ];
+                        'subscriptionList' => $resp['subscriptionList'],
+                        'next_offset'      => $next_offset, ];
     }
 }

src/Queue/Driver/CMQExceptionBase.php

Indentation +2 added lines, -2 removed lines

@@ -37,8 +37,8 @@
     public function get_info()
     {
         $info = ['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/QueueMeta.php

Indentation +13 added lines, -13 removed lines

@@ -59,19 +59,19 @@
     public function __toString()
     {
         $info = ['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/CMQServerNetworkException.php

Indentation +2 added lines, -2 removed lines

@@ -23,8 +23,8 @@
     public function __toString()
     {
         $info = ['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/Message.php

Indentation +6 added lines, -6 removed lines

@@ -38,12 +38,12 @@
     public function __toString()
     {
         $info = ['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/Account.php

Indentation +3 added lines, -3 removed lines

@@ -129,7 +129,7 @@ 
         }
 
         return ['totalCount'      => $ret_pkg['totalCount'],
-                     'queueList'  => $ret_pkg['queueList'], 'next_offset' => $next_offset, ];
+                        'queueList'  => $ret_pkg['queueList'], 'next_offset' => $next_offset, ];
     }
 
     /* 列出Account的主题
@@ -171,8 +171,8 @@ 
         }
 
         return ['totalCoult'       => $resp['totalCount'],
-                     'topicList'   => $resp['topicList'],
-                     'next_offset' => $next_offset, ];
+                        'topicList'   => $resp['topicList'],
+                        'next_offset' => $next_offset, ];
     }
 
     /* 获取Account的一个Topic对象

src/Queue/Driver/ResponseInternal.php

Indentation +2 added lines, -2 removed lines

@@ -21,8 +21,8 @@
     public function __toString()
     {
         $info = ['status'      => $this->status,
-                      'header' => json_encode($this->header),
-                      'data'   => $this->data, ];
+                        'header' => json_encode($this->header),
+                        'data'   => $this->data, ];
 
         return json_encode($info);
     }