fix: crash on accessing $currentJob before initialization

oprudkyi · oprudkyi · commit 1b9ff657a6d5 · 2023-06-01T21:57:56.000+03:00
diff --git a/src/Queue/RabbitMQQueue.php b/src/Queue/RabbitMQQueue.php
@@ -577,7 +577,7 @@ protected function getRandomId(): string
      */
     public function close(): void
     {
-        if (! $this->currentJob->isDeletedOrReleased()) {
+        if (isset($this->currentJob) && ! $this->currentJob->isDeletedOrReleased()) {
             $this->reject($this->currentJob, true);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -577,7 +577,7 @@ protected function getRandomId(): string`
`577`	`577`	`*/`
`578`	`578`	`public function close(): void`
`579`	`579`	`{`
`580`		`- if (! $this->currentJob->isDeletedOrReleased()) {`
	`580`	`+ if (isset($this->currentJob) && ! $this->currentJob->isDeletedOrReleased()) {`
`581`	`581`	`$this->reject($this->currentJob, true);`
`582`	`582`	`}`
`583`	`583`