Skip to content

Commit a83eff9

Browse files
authored
Merge pull request #530 from vyuldashev/increase-compatibility
Honor the 'rest' option
2 parents 53d4895 + e54d287 commit a83eff9

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)