diff --git a/src/Consumer.php b/src/Consumer.php index bd7f099d..ed3d8099 100644 --- a/src/Consumer.php +++ b/src/Consumer.php @@ -125,6 +125,10 @@ function (AMQPMessage $message) use ($connection, $options, $connectionName, $qu if ($this->supportsAsyncSignals()) { $this->resetTimeoutHandler(); } + + if ($options->rest > 0) { + $this->sleep($options->rest); + } }, null, $arguments