ouqiang / delayqueue-php

src/Process/Worker.php

Spacing +4 added lines, -4 removed lines

@@ -31,7 +31,7 @@ 
     public function run()
     {
         $this->registerSignalHandlers();
-        while(true) {
+        while (true) {
             if ($this->shutdown) {
                 break;
             }
@@ -50,7 +50,7 @@ 
 
             try {
                 $this->delayQueue->validateClassName($data['className']);
-            } catch(Exception $exception) {
+            } catch (Exception $exception) {
                 $this->logger->emergency($exception->getMessage());
                 continue;
             }
@@ -62,7 +62,7 @@ 
     protected function perform(array $data)
     {
         $pid = pcntl_fork();
-        if ($pid< 0) {
+        if ($pid<0) {
             $this->logger->emergency('Unable to fork child worker', ['job' => $data]);
             return;
         }
@@ -93,7 +93,7 @@ 
     protected function registerSignalHandlers()
     {
         pcntl_signal(SIGTERM, [$this, 'shutdown']);
-        pcntl_signal(SIGINT , [$this, 'shutdown']);
+        pcntl_signal(SIGINT, [$this, 'shutdown']);
     }
 
     /**

src/DelayQueue.php

Spacing +2 added lines, -2 removed lines

@@ -82,7 +82,7 @@ 
             ]
         ]);
 
-        $data =  $response->json();
+        $data = $response->json();
         $this->checkResponseBody($data);
         if (!isset($data['data']) || empty($data['data'])) {
             return null;
@@ -120,7 +120,7 @@ 
                'id' => $id
             ]
         ]);
-        $body =  $response->json();
+        $body = $response->json();
         $this->checkResponseBody($body);
     }