Skip to content

Commit 35ab32c

Browse files
committed
Merge branch 'master' into fix/refactor-creation-of-connections-and-queues
2 parents bf18827 + a83eff9 commit 35ab32c

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/Consumer.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -125,6 +125,10 @@ function (AMQPMessage $message) use ($connection, $options, $connectionName, $qu
125125
if ($this->supportsAsyncSignals()) {
126126
$this->resetTimeoutHandler();
127127
}
128+
129+
if ($options->rest > 0) {
130+
$this->sleep($options->rest);
131+
}
128132
},
129133
null,
130134
$arguments

0 commit comments

Comments
 (0)