Catch signal in Bunny adapter

snapshotpl · snapshotpl · commit 38ed92545f80 · 2019-02-20T16:57:52.000+01:00
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 ('stream_select() failed' === substr($e->getMessage(), 0, 22) && $signalHandler->wasThereSignal()) {
                 return;
             }
 

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`