PHP Linting (Pint)

Author: iamfarhad

src/RabbitQueue.php

@@ -132,7 +132,7 @@ public function push($job, $data = '', $queue = null): ?string
             $this->createPayload($job, $this->getQueue($queue), $data),
             $queue,
             null,
-            fn($payload, $queue) => $this->pushRaw($payload, $queue)
+            fn ($payload, $queue) => $this->pushRaw($payload, $queue)
         );
     }
 
@@ -171,7 +171,7 @@ public function later($delay, $job, $data = '', $queue = null): ?string
             $this->createPayload($job, $this->getQueue($queue), $data),
             $queue,
             $delay,
-            fn($payload, $queue, $delay) => $this->laterRaw($delay, $payload, $queue)
+            fn ($payload, $queue, $delay) => $this->laterRaw($delay, $payload, $queue)
         );
     }
 
@@ -195,7 +195,7 @@ public function laterRaw($delay, $payload, $queue = null, $attempts = 2): ?strin
         }
 
         $queueName = $this->getQueue($queue);
-        $delayQueueName = $queueName . '.delay.' . $ttl;
+        $delayQueueName = $queueName.'.delay.'.$ttl;
 
         $this->declareDelayQueue($delayQueueName, $queueName, $ttl);
 
@@ -260,7 +260,7 @@ public function pop($queue = null)
         } catch (AMQPConnectionException $exception) {
             // Replace with a more specific exception that Laravel's worker can detect as a lost connection
             throw new Exception(
-                'Lost connection: ' . $exception->getMessage(),
+                'Lost connection: '.$exception->getMessage(),
                 $exception->getCode(),
                 $exception
             );
@@ -357,7 +357,7 @@ public function declareQueue(
             }
 
             $amqpQueue->declareQueue();
-        } catch (AMQPChannelException | AMQPQueueException $exception) {
+        } catch (AMQPChannelException|AMQPQueueException $exception) {
             // If it's not a "queue already exists" or "unknown delivery tag" case, re-throw
             if ($exception->getCode() !== self::QUEUE_ALREADY_EXISTS_CODE) {
                 throw $exception;
@@ -418,7 +418,7 @@ public function reject(RabbitMQJob $rabbitMQJob, bool $requeue = false): void
             $amqpQueue = new AMQPQueue($this->getChannel());
             $amqpQueue->setName($rabbitMQJob->getQueue());
             $amqpQueue->reject($deliveryTag, $requeue ? AMQP_REQUEUE : AMQP_NOPARAM);
-        } catch (AMQPChannelException | AMQPConnectionException $exception) {
+        } catch (AMQPChannelException|AMQPConnectionException $exception) {
             // Reopen channel and try again
             $this->releaseChannel();
             $amqpQueue = new AMQPQueue($this->getChannel());
@@ -448,7 +448,7 @@ public function ack(RabbitMQJob $rabbitMQJob, int $maxRetries = self::MAX_RETRY_
                 $amqpQueue->ack($deliveryTag);
 
                 return; // Acknowledgment successful
-            } catch (AMQPChannelException | AMQPConnectionException $exception) {
+            } catch (AMQPChannelException|AMQPConnectionException $exception) {
                 // Recreate channel instead of setting to null
                 $this->releaseChannel();
                 $attempts++;
@@ -556,7 +556,7 @@ private function publishMessage(string $payload, string $queueName, int $attempt
 
         try {
             return $this->doPublish($payload, $queueName, $messageAttributes);
-        } catch (AMQPChannelException | AMQPConnectionException) {
+        } catch (AMQPChannelException|AMQPConnectionException) {
             // Reopen channel and try again
             $this->releaseChannel();
 

src/Support/ExchangeManager.php

@@ -131,7 +131,7 @@ public function setupDeadLetterExchange(
         $this->declareExchange($dlxName, $dlxType, true, false);
 
         // Create dead letter queue
-        $dlqName = $queueName . '.dlq';
+        $dlqName = $queueName.'.dlq';
         $dlq = new AMQPQueue($this->channel);
         $dlq->setName($dlqName);
         $dlq->setFlags(AMQP_DURABLE);

src/Support/PublisherConfirms.php

@@ -34,7 +34,7 @@ public function enable(): void
             $this->channel->confirmSelect();
             $this->confirmMode = true;
         } catch (AMQPChannelException $e) {
-            throw new Exception('Failed to enable publisher confirms: ' . $e->getMessage(), 0, $e);
+            throw new Exception('Failed to enable publisher confirms: '.$e->getMessage(), 0, $e);
         }
     }
 
@@ -58,9 +58,10 @@ public function waitForConfirms(): bool
         }
         try {
             $this->channel->waitForConfirm($this->timeout);
+
             return true;
         } catch (AMQPChannelException $e) {
-            throw new Exception('Failed to wait for confirms: ' . $e->getMessage(), 0, $e);
+            throw new Exception('Failed to wait for confirms: '.$e->getMessage(), 0, $e);
         }
     }