mikopbx / Core

src/Core/System/BeanstalkClient.php

Spacing +12 added lines, -12 removed lines

@@ -48,12 +48,12 @@ 
     {
         $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;
         }
         $this->queue = Pheanstalk::create($config->host, $port);
         $this->queue->useTube($this->tube);
-        foreach ($this->subscriptions as $tube => $callback){
+        foreach ($this->subscriptions as $tube => $callback) {
             $this->subscribe($tube, $callback);
         }
         $this->connected = true;
@@ -104,7 +104,7 @@ 
                 $this->queue->delete($job);
             }
         } catch (Throwable $exception) {
-            Util::sysLogMsg(__METHOD__, 'Exception: ' . $exception->getMessage());
+            Util::sysLogMsg(__METHOD__, 'Exception: '.$exception->getMessage());
             if ($job !== null) {
                 $this->queue->bury($job);
             }
@@ -136,7 +136,7 @@ 
     ): Job {
         $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);
@@ -161,10 +161,10 @@ 
                 $queueStats = $this->queue->stats()->getArrayCopy();
 
                 // Delete buried jobs
-                $countBuried=$queueStats['current-jobs-buried'];
+                $countBuried = $queueStats['current-jobs-buried'];
                 while ($job = $this->queue->peekBuried()) {
                     $countBuried--;
-                    if ($countBuried<0){
+                    if ($countBuried < 0) {
                         break;
                     }
                     $id = $job->getId();
@@ -173,23 +173,23 @@ 
                 }
 
                 // Delete outdated jobs
-                $countReady=$queueStats['current-jobs-ready'];
+                $countReady = $queueStats['current-jobs-ready'];
                 while ($job = $this->queue->peekReady()) {
                     $countReady--;
-                    if ($countReady<0){
+                    if ($countReady < 0) {
                         break;
                     }
                     $id = $job->getId();
                     $jobStats = $this->queue->statsJob($job)->getArrayCopy();
-                    $age                   = (int)$jobStats['age'];
-                    $expectedTimeToExecute = (int)$jobStats['ttr'] * 2;
+                    $age                   = (int) $jobStats['age'];
+                    $expectedTimeToExecute = (int) $jobStats['ttr'] * 2;
                     if ($age > $expectedTimeToExecute) {
                         $this->queue->delete($job);
                         Util::sysLogMsg(__METHOD__, "Deleted outdated job with ID {$id} from {$tube}");
                     }
                 }
             } catch (Throwable $exception) {
-                Util::sysLogMsg(__METHOD__, 'Exception: ' . $exception->getMessage());
+                Util::sysLogMsg(__METHOD__, 'Exception: '.$exception->getMessage());
             }
         }
     }
@@ -222,7 +222,7 @@ 
         try {
             $job = $this->queue->reserveWithTimeout($timeout);
         } catch (Throwable $exception) {
-            Util::sysLogMsg(__METHOD__, 'Exception: ' . $exception->getMessage());
+            Util::sysLogMsg(__METHOD__, 'Exception: '.$exception->getMessage());
         }
 
         if ($job === null) {