ending the battle with pint

Author: khepin

src/Horizon/RabbitMQQueue.php

@@ -18,7 +18,7 @@ class RabbitMQQueue extends BaseRabbitMQQueue
     /**
      * The job that last pushed to queue via the "push" method.
      */
-    protected string|object $lastPushed = '';
+    protected string|object $lastPushed;
 
     /**
      * Get the number of queue jobs that are ready to process.
@@ -48,7 +48,7 @@ public function push($job, $data = '', $queue = null)
      */
     public function pushRaw($payload, $queue = null, array $options = []): int|string|null
     {
-        $payload = (new JobPayload($payload))->prepare($this->lastPushed)->value;
+        $payload = (new JobPayload($payload))->prepare($this->lastPushed ?? null)->value;
 
         return tap(parent::pushRaw($payload, $queue, $options), function () use ($queue, $payload): void {
             $this->event($this->getQueue($queue), new JobPushed($payload));

src/Queue/RabbitMQQueue.php

@@ -631,7 +631,7 @@ protected function getDelayQueueArguments(string $destination, int $ttl): array
     /**
      * Get the exchange name, or empty string; as default value.
      */
-    protected function getExchange(?string $exchange = null): string
+    protected function getExchange(string $exchange = null): string
     {
         return $exchange ?? $this->getConfig()->getExchange();
     }
@@ -648,7 +648,7 @@ protected function getRoutingKey(string $destination): string
     /**
      * Get the exchangeType, or AMQPExchangeType::DIRECT as default.
      */
-    protected function getExchangeType(?string $type = null): string
+    protected function getExchangeType(string $type = null): string
     {
         $constant = AMQPExchangeType::class.'::'.Str::upper($type ?: $this->getConfig()->getExchangeType());
 
@@ -658,7 +658,7 @@ protected function getExchangeType(?string $type = null): string
     /**
      * Get the exchange for failed messages.
      */
-    protected function getFailedExchange(?string $exchange = null): string
+    protected function getFailedExchange(string $exchange = null): string
     {
         return $exchange ?? $this->getConfig()->getFailedExchange();
     }
@@ -693,7 +693,7 @@ protected function isQueueDeclared(string $name): bool
      *
      * @throws AMQPProtocolChannelException
      */
-    protected function declareDestination(string $destination, ?string $exchange = null, string $exchangeType = AMQPExchangeType::DIRECT): void
+    protected function declareDestination(string $destination, string $exchange = null, string $exchangeType = AMQPExchangeType::DIRECT): void
     {
         // When an exchange is provided and no exchange is present in RabbitMQ, create an exchange.
         if ($exchange && ! $this->isExchangeExists($exchange)) {