Skip to content

Commit 651c895

Browse files
authored
Update Consumer.php
1 parent 6c17be8 commit 651c895

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/Consumer.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ public function daemon($connectionName, $queue, WorkerOptions $options)
8888
$this->channel->basic_qos(
8989
$this->prefetchSize,
9090
$this->prefetchCount,
91-
null
91+
false
9292
);
9393

9494
$jobClass = $connection->getJobClass();
@@ -147,7 +147,7 @@ function (AMQPMessage $message) use ($connection, $options, $connectionName, $qu
147147
} catch (AMQPRuntimeException $exception) {
148148
$this->exceptions->report($exception);
149149

150-
$this->kill(1);
150+
$this->kill(self::EXIT_ERROR, $options);
151151
} catch (Exception|Throwable $exception) {
152152
$this->exceptions->report($exception);
153153

@@ -171,7 +171,7 @@ function (AMQPMessage $message) use ($connection, $options, $connectionName, $qu
171171
);
172172

173173
if (! is_null($status)) {
174-
return $this->stop($status);
174+
return $this->stop($status, $options);
175175
}
176176

177177
$this->currentJob = null;

0 commit comments

Comments
 (0)