Skip to content

Commit f2bd621

Browse files
committed
Check if exists
1 parent cf6b3ac commit f2bd621

1 file changed

Lines changed: 5 additions & 3 deletions

File tree

src/Command/QueueReceiveCommand.php

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -100,9 +100,11 @@ private function pollQueue($registry, $name)
100100
$dispatcher = $this->container->get('event_dispatcher');
101101
$messages = $registry->get($name)->receive();
102102

103-
foreach ($messages as $message) {
104-
$messageEvent = new MessageEvent($name, $message);
105-
$dispatcher->dispatch(Events::Message($name), $messageEvent);
103+
if($messages) {
104+
foreach ($messages as $message) {
105+
$messageEvent = new MessageEvent($name, $message);
106+
$dispatcher->dispatch(Events::Message($name), $messageEvent);
107+
}
106108
}
107109

108110
$msg = "<info>Finished polling %s Queue, %d messages fetched.</info>";

0 commit comments

Comments
 (0)