Skip to content

Commit f641ab1

Browse files
authored
Fix worker getting killed by timeout when no more jobs available
1 parent 0ce0f95 commit f641ab1

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/Consumer.php

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,11 @@ function (AMQPMessage $message) use ($connection, $options, $connectionName, $qu
9797
}
9898

9999
$this->runJob($job, $connectionName, $options);
100+
101+
102+
if ($this->supportsAsyncSignals()) {
103+
$this->resetTimeoutHandler();
104+
}
100105
}
101106
);
102107

0 commit comments

Comments
 (0)