sroze / messenger-enqueue-transport

Uses Enqueue with Symfony's Messenger component.
MIT License
191 stars 55 forks source link

Add flush($timeout) method optional call for sending messages through Enqueue\RdKafka to make it sync #121

Open Vorotyagin-Anton opened 1 year ago

Vorotyagin-Anton commented 1 year ago

In Enqueue\RdKafka\RdKafkaProducer $timeout === 0 is hardcoded in method send() call. So, the only way to wait for delivery report to handle errors is calling flush(-1) method from Enqueue\RdKafka\RdKafkaProducer. But it is not implemented in Enqueue\MessengerAdapter\QueueInteropTransport send method.