Commit 38ed925

committed

Catch signal in Bunny adapter

1 parent b38e40a commit 38ed925Copy full SHA for 38ed925

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ public function consume(int $timeout = 0): void`
`47`	`47`	`try {`
`48`	`48`	`$this->context->getBunnyChannel()->getClient()->run(0 !== $timeout ? $timeout / 1000 : null);`
`49`	`49`	`} catch (ClientException $e) {`
`50`		`- if ('stream_select() failed.' ==$e->getMessage() && $signalHandler->wasThereSignal()) {`
	`50`	`+ if ('stream_select() failed' === substr($e->getMessage(), 0, 22) && $signalHandler->wasThereSignal()) {`
`51`	`51`	`return;`
`52`	`52`	`}`
`53`	`53`

Comments

(0)