Merge pull request #771 from snapshotpl/bunny-signal

Catch signal in Bunny adapter
php-enqueue · Feb 21, 2019 · 499360e · 499360e
2 parents b38e40a + 62cb949
commit 499360e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/amqp-bunny/AmqpSubscriptionConsumer.php b/pkg/amqp-bunny/AmqpSubscriptionConsumer.php
@@ -47,7 +47,7 @@ public function consume(int $timeout = 0): void
         try {
             $this->context->getBunnyChannel()->getClient()->run(0 !== $timeout ? $timeout / 1000 : null);
         } catch (ClientException $e) {
-            if ('stream_select() failed.' == $e->getMessage() && $signalHandler->wasThereSignal()) {
+            if (0 === strpos($e->getMessage(), 'stream_select() failed') && $signalHandler->wasThereSignal()) {
                 return;
             }