KonstantinCodes / messenger-kafka

Simple Kafka transport for Symfony Messenger.
MIT License
84 stars 35 forks source link

Removed message waiting cycle #1

Closed andsm closed 5 years ago

andsm commented 5 years ago

Symfony messenger's worker already using cycle https://github.com/symfony/messenger/blob/master/Worker.php#L83 As a result, it is impossible to properly stop the worker in the absence of messages.