Apply fixes from StyleCI

src/Queue/Jobs/StompJob.php

@@ -11,7 +11,6 @@
 use Illuminate\Queue\Jobs\JobName;
 use Illuminate\Support\Arr;
 use Illuminate\Support\Facades\Event;
-use Illuminate\Support\Facades\Log;
 use Illuminate\Support\Str;
 use Psr\Log\LoggerInterface;
 use Stomp\Transport\Frame;
@@ -113,6 +112,7 @@ public function fire()
     protected function isNativeLaravelJob(): bool
     {
         $job = Arr::get($this->payload, 'job');
+
         return $job && str_contains($job, 'CallQueuedHandler@call');
     }
 
@@ -183,9 +183,9 @@ protected function getSubscriptionName(): string
     public function delete()
     {
         $this->log->info("$this->session [STOMP] Deleting a message from queue: " . print_r([
-                'queue' => $this->queue,
-                'message' => $this->frame,
-            ], true));
+            'queue' => $this->queue,
+            'message' => $this->frame,
+        ], true));
 
         parent::delete();
     }
@@ -204,7 +204,6 @@ public function release($delay = 0)
             $payload = $this->createStompPayload($delay);
             $this->stompQueue->pushRaw($payload, $this->queue, []);
         }
-
     }
 
     protected function createStompPayload(int $delay): Message
@@ -260,5 +259,4 @@ protected function failed($e)
             $this->log->error('Exception in job failing: ' . $e->getMessage());
         }
     }
-
 }

src/Queue/StompQueue.php

@@ -216,10 +216,10 @@ protected function writeToMultipleQueues(array $writeQueues, Message $payload):
          * @var $payload Message
          */
         $this->log->info("$this->session [STOMP] Pushing stomp payload to queue: " . print_r([
-                'body' => $payload->getBody(),
-                'headers' => $payload->getHeaders(),
-                'queue' => $writeQueues,
-            ], true));
+            'body' => $payload->getBody(),
+            'headers' => $payload->getHeaders(),
+            'queue' => $writeQueues,
+        ], true));
 
         $allEventsSent = true;
 
@@ -238,7 +238,7 @@ protected function writeToMultipleQueues(array $writeQueues, Message $payload):
         return $allEventsSent;
     }
 
-    protected function write($queue, Message $payload, $tryAgain=true): bool
+    protected function write($queue, Message $payload, $tryAgain = true): bool
     {
         // This will write all the events received in a single batch, then send disconnect frame
         try {
@@ -253,9 +253,9 @@ protected function write($queue, Message $payload, $tryAgain=true): bool
 
             if ($tryAgain) {
                 $this->log->info("$this->session [STOMP] Trying to send again...");
+
                 return $this->write($queue, $payload, false);
             }
-
         }
     }
 
@@ -468,6 +468,7 @@ protected function reconnect(bool $subscribe = true)
             }
 
             $this->log->error("$this->session [STOMP] Circuit breaker executed after {$this->circuitBreaker} tries, exiting.");
+
             return;
         }
 
@@ -531,5 +532,4 @@ public function ackLastFrameIfNecessary()
             $this->_lastFrame = null;
         }
     }
-
 }

src/StompServiceProvider.php

@@ -47,6 +47,7 @@ public function boot()
 
         app()->singleton('stompLog', function ($app) use ($logsEnabled) {
             $logManager = config('asseco-stomp.log_manager');
+
             return $logsEnabled ? new $logManager($app) : new NullLogger();
         });
     }