diff --git a/Queue/Queue.php b/Queue/Queue.php index cde52628..6a5296e6 100644 --- a/Queue/Queue.php +++ b/Queue/Queue.php @@ -81,7 +81,13 @@ class Queue extends \Snowflake\Process\Process */ public function delivery(Consumer $consumer, $score = 0) { - $this->waiting->add($consumer, $score); + try { + $consumer->onWaiting(); + } catch (\Throwable $exception) { + $this->application->error($exception->getMessage()); + } finally { + $this->waiting->add($consumer, $score); + } } diff --git a/System/Abstracts/BaseObject.php b/System/Abstracts/BaseObject.php index caae0144..dec00e44 100644 --- a/System/Abstracts/BaseObject.php +++ b/System/Abstracts/BaseObject.php @@ -169,7 +169,7 @@ class BaseObject implements Configure * @param string $message * @param string|null $method * @param string|null $file - * @throws Exception + * @throws */ public function error($message, $method = null, $file = null) {