blocking messenger consumer

melihovv · melihovv · commit a6dc921c77d0 · 2023-07-05T01:12:10.000+03:00
diff --git a/src/Symfony/Component/Messenger/Worker.php b/src/Symfony/Component/Messenger/Worker.php
@@ -104,10 +104,8 @@ public function run(array $options = []): void
                     if (!$receiver instanceof QueueBlockingReceiverInterface) {
                         throw new RuntimeException(sprintf('Receiver for "%s" does not implement "%s".', $transportName, QueueBlockingReceiverInterface::class));
                     }
-                } else {
-                    if (!$receiver instanceof QueueReceiverInterface) {
-                        throw new RuntimeException(sprintf('Receiver for "%s" does not implement "%s".', $transportName, QueueReceiverInterface::class));
-                    }
+                } elseif (!$receiver instanceof QueueReceiverInterface) {
+                    throw new RuntimeException(sprintf('Receiver for "%s" does not implement "%s".', $transportName, QueueReceiverInterface::class));
                 }
             }
         }
@@ -130,10 +128,10 @@ public function run(array $options = []): void
                     };
 
                     if ($queueNames) {
-                        /* @var QueueBlockingReceiverInterface $receiver */
+                        /** @var QueueBlockingReceiverInterface $receiver */
                         $receiver->pullFromQueues($queueNames, $callback);
                     } else {
-                        /* @var BlockingReceiverInterface $receiver */
+                        /** @var BlockingReceiverInterface $receiver */
                         $receiver->pull($callback);
                     }
                 } else {

Original file line number	Diff line number	Diff line change
`@@ -104,10 +104,8 @@ public function run(array $options = []): void`
`104`	`104`	`if (!$receiver instanceof QueueBlockingReceiverInterface) {`
`105`	`105`	`throw new RuntimeException(sprintf('Receiver for "%s" does not implement "%s".', $transportName, QueueBlockingReceiverInterface::class));`
`106`	`106`	`}`
`107`		`- } else {`
`108`		`- if (!$receiver instanceof QueueReceiverInterface) {`
`109`		`- throw new RuntimeException(sprintf('Receiver for "%s" does not implement "%s".', $transportName, QueueReceiverInterface::class));`
`110`		`- }`
	`107`	`+ } elseif (!$receiver instanceof QueueReceiverInterface) {`
	`108`	`+ throw new RuntimeException(sprintf('Receiver for "%s" does not implement "%s".', $transportName, QueueReceiverInterface::class));`
`111`	`109`	`}`
`112`	`110`	`}`
`113`	`111`	`}`
`@@ -130,10 +128,10 @@ public function run(array $options = []): void`
`130`	`128`	`};`
`131`	`129`
`132`	`130`	`if ($queueNames) {`
`133`		`- /* @var QueueBlockingReceiverInterface $receiver */`
	`131`	`+ /** @var QueueBlockingReceiverInterface $receiver */`
`134`	`132`	`$receiver->pullFromQueues($queueNames, $callback);`
`135`	`133`	`} else {`
`136`		`- /* @var BlockingReceiverInterface $receiver */`
	`134`	`+ /** @var BlockingReceiverInterface $receiver */`
`137`	`135`	`$receiver->pull($callback);`
`138`	`136`	`}`
`139`	`137`	`} else {`