freyo / laravel-queue-cmq

src/Queue/CMQQueue.php

Spacing +7 added lines, -7 removed lines

@@ -76,7 +76,7 @@ 
      */
     public function isPlain()
     {
-        return (bool) Arr::get($this->plainOptions, 'enable');
+        return (bool)Arr::get($this->plainOptions, 'enable');
     }
 
     /**
@@ -98,7 +98,7 @@ 
     {
         $attributes = $this->getQueue($queue)->get_attributes();
 
-        return (int) $attributes->activeMsgNum;
+        return (int)$attributes->activeMsgNum;
     }
 
     /**
@@ -148,22 +148,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));
         });
     }
@@ -210,7 +210,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 null;
             }