diff --git a/src/Worker.php b/src/Worker.php index 2a0c1f8..e2696d9 100644 --- a/src/Worker.php +++ b/src/Worker.php @@ -157,7 +157,7 @@ public function onResult(MessageResult $context): void } } - public function stop($status = 0) + public function stop($status = 0, $options = null) { if ($this->interop) { $this->stopped = true; @@ -165,7 +165,7 @@ public function stop($status = 0) return; } - parent::stop($status); + parent::stop($status, $options); } public function setExtensions(array $extensions): self