mikopbx / Core

src/Core/System/BeanstalkClient.php

Spacing +15 added lines, -15 removed lines

@@ -36,7 +36,7 @@ 
      */
     public function __construct($tube = 'default', $port = '')
     {
-        $this->tube        = str_replace("\\", '-', $tube);;
+        $this->tube        = str_replace("\\", '-', $tube); ;
         $this->job_options = ['priority' => 250, 'delay' => 0, 'ttr' => 3600];
         $this->port = $port;
         $this->reconnect();
@@ -49,7 +49,7 @@ 
     {
         $config = $this->di->get('config')->beanstalk;
         $port   = $config->port;
-        if(!empty($this->port) && is_numeric($this->port)){
+        if (!empty($this->port) && is_numeric($this->port)) {
             $port = $this->port;
         }
 
@@ -126,7 +126,7 @@ 
     {
         $tube = str_replace("\\", '-', $tube);
         // Change tube
-        if ( ! empty($tube) && $this->tube !== $tube) {
+        if (!empty($tube) && $this->tube !== $tube) {
             $this->queue->useTube($tube);
         }
         $job_data = serialize($job_data);
@@ -178,9 +178,9 @@ 
         }
 
         // Processing job over callable function attached in $this->subscribe
-        if(json_decode($job->getData(), true) !==null){
-            $mData =  $job->getData();
-        }else{
+        if (json_decode($job->getData(), true) !== null) {
+            $mData = $job->getData();
+        } else {
             $mData = unserialize($job->getData(), [false]);
         }
         $this->message = $mData;
@@ -197,8 +197,8 @@ 
 
         try {
             $this->queue->delete($job);
-        }catch (\Pheanstalk\Exception\JobNotFoundException $e){
-        }catch (\Error $e){
+        } catch (\Pheanstalk\Exception\JobNotFoundException $e) {
+        } catch (\Error $e) {
         }
     }
 
@@ -263,28 +263,28 @@ 
     /**
      * Drops orphaned tasks
      */
-    public function cleanTube(){
+    public function cleanTube() {
         $tubes = $this->queue->listTubes();
-        foreach ($tubes as $tube){
-            if(strpos($tube, "INBOX_") !== 0){
+        foreach ($tubes as $tube) {
+            if (strpos($tube, "INBOX_") !== 0) {
                 continue;
             }
             try {
                 $statData = $this->queue->statsTube($tube)->getArrayCopy();
                 $watching = $statData['current-watching'];
-                if($watching !== '0'){
+                if ($watching !== '0') {
                     continue;
                 }
                 // Нужно удалить все Jobs.
                 $this->queue->watch($tube);
-                while (true){
+                while (true) {
                     $job = $this->queue->reserveWithTimeout(1);
-                    if($job === null){
+                    if ($job === null) {
                         break;
                     }
                     $this->queue->delete($job);
                 }
-            }catch (\Exception $e){
+            } catch (\Exception $e) {
                 continue;
             }
 

Braces +7 added lines, -7 removed lines

@@ -83,8 +83,7 @@ 
         $job_data,
         int $timeout = 10,
         int $priority = PheanstalkInterface::DEFAULT_PRIORITY
-    )
-    {
+    ) {
         $this->message = false;
         $inbox_tube    = uniqid('INBOX_', true);
         $this->queue->watch($inbox_tube);
@@ -180,7 +179,7 @@ 
         // Processing job over callable function attached in $this->subscribe
         if(json_decode($job->getData(), true) !==null){
             $mData =  $job->getData();
-        }else{
+        } else{
             $mData = unserialize($job->getData(), [false]);
         }
         $this->message = $mData;
@@ -197,8 +196,8 @@ 
 
         try {
             $this->queue->delete($job);
-        }catch (\Pheanstalk\Exception\JobNotFoundException $e){
-        }catch (\Error $e){
+        } catch (\Pheanstalk\Exception\JobNotFoundException $e){
+        } catch (\Error $e){
         }
     }
 
@@ -263,7 +262,8 @@ 
     /**
      * Drops orphaned tasks
      */
-    public function cleanTube(){
+    public function cleanTube()
+    {
         $tubes = $this->queue->listTubes();
         foreach ($tubes as $tube){
             if(strpos($tube, "INBOX_") !== 0){
@@ -284,7 +284,7 @@ 
                     }
                     $this->queue->delete($job);
                 }
-            }catch (\Exception $e){
+            } catch (\Exception $e){
                 continue;
             }