blocking messenger consumer

melihovv · melihovv · commit e579ac63a672 · 2023-07-05T00:36:44.000+03:00
diff --git a/src/Symfony/Component/Messenger/Bridge/Amqp/Transport/AmqpReceiver.php b/src/Symfony/Component/Messenger/Bridge/Amqp/Transport/AmqpReceiver.php
@@ -42,17 +42,11 @@ public function get(): iterable
         yield from $this->getFromQueues($this->connection->getQueueNames());
     }
 
-    /**
-     * {@inheritdoc}
-     */
     public function pull(callable $callback): void
     {
         $this->pullFromQueues($this->connection->getQueueNames(), $callback);
     }
 
-    /**
-     * {@inheritdoc}
-     */
     public function pullFromQueues(array $queueNames, callable $callback): void
     {
         if (0 === \count($queueNames)) {
@@ -88,9 +82,6 @@ private function pullEnvelope(string $queueName, ?callable $callback): void
         }
     }
 
-    /**
-     * {@inheritdoc}
-     */
     public function getFromQueues(array $queueNames): iterable
     {
         foreach ($queueNames as $queueName) {
diff --git a/src/Symfony/Component/Messenger/Bridge/Amqp/Transport/AmqpTransport.php b/src/Symfony/Component/Messenger/Bridge/Amqp/Transport/AmqpTransport.php
@@ -41,25 +41,16 @@ public function get(): iterable
         return $this->getReceiver()->get();
     }
 
-    /**
-     * {@inheritdoc}
-     */
     public function pull(callable $callback): void
     {
         $this->getReceiver()->pull($callback);
     }
 
-    /**
-     * {@inheritdoc}
-     */
     public function pullFromQueues(array $queueNames, callable $callback): void
     {
         $this->receiver->pullFromQueues($queueNames, $callback);
     }
 
-    /**
-     * {@inheritdoc}
-     */
     public function getFromQueues(array $queueNames): iterable
     {
         return $this->getReceiver()->getFromQueues($queueNames);

Original file line number	Diff line number	Diff line change
`@@ -42,17 +42,11 @@ public function get(): iterable`
`42`	`42`	`yield from $this->getFromQueues($this->connection->getQueueNames());`
`43`	`43`	`}`
`44`	`44`
`45`		`- /**`
`46`		`- * {@inheritdoc}`
`47`		`- */`
`48`	`45`	`public function pull(callable $callback): void`
`49`	`46`	`{`
`50`	`47`	`$this->pullFromQueues($this->connection->getQueueNames(), $callback);`
`51`	`48`	`}`
`52`	`49`
`53`		`- /**`
`54`		`- * {@inheritdoc}`
`55`		`- */`
`56`	`50`	`public function pullFromQueues(array $queueNames, callable $callback): void`
`57`	`51`	`{`
`58`	`52`	`if (0 === \count($queueNames)) {`
`@@ -88,9 +82,6 @@ private function pullEnvelope(string $queueName, ?callable $callback): void`
`88`	`82`	`}`
`89`	`83`	`}`
`90`	`84`
`91`		`- /**`
`92`		`- * {@inheritdoc}`
`93`		`- */`
`94`	`85`	`public function getFromQueues(array $queueNames): iterable`
`95`	`86`	`{`
`96`	`87`	`foreach ($queueNames as $queueName) {`
Original file line number	Diff line number	Diff line change
`@@ -41,25 +41,16 @@ public function get(): iterable`
`41`	`41`	`return $this->getReceiver()->get();`
`42`	`42`	`}`
`43`	`43`
`44`		`- /**`
`45`		`- * {@inheritdoc}`
`46`		`- */`
`47`	`44`	`public function pull(callable $callback): void`
`48`	`45`	`{`
`49`	`46`	`$this->getReceiver()->pull($callback);`
`50`	`47`	`}`
`51`	`48`
`52`		`- /**`
`53`		`- * {@inheritdoc}`
`54`		`- */`
`55`	`49`	`public function pullFromQueues(array $queueNames, callable $callback): void`
`56`	`50`	`{`
`57`	`51`	`$this->receiver->pullFromQueues($queueNames, $callback);`
`58`	`52`	`}`
`59`	`53`
`60`		`- /**`
`61`		`- * {@inheritdoc}`
`62`		`- */`
`63`	`54`	`public function getFromQueues(array $queueNames): iterable`
`64`	`55`	`{`
`65`	`56`	`return $this->getReceiver()->getFromQueues($queueNames);`