Merge pull request vyuldashev#556 from vyuldashev/fix-lastpushed

Fix issue where  was accessed before initialization

Author: adm-bome

src/Horizon/RabbitMQQueue.php

@@ -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)) {