search

qweeze / rstream

A Python asyncio-based client for RabbitMQ Streams
MIT License
83 stars 13 forks source link

Reliable example / Consumer improvements during Metadata updates #181

Closed DanielePalaia closed 7 months ago

DanielePalaia commented 9 months ago

This closes #175

Disconnection and Metadata update examples have been deleted and replaced by a more complete reliable example.

Also running this example few issues were discovered during Metadata Update on Consumer side.

When there was a Metadata update che client was closing the old connection with all streams connected and just re-recreated a new one for the stream affected during Metadata Update.

This PR should fix the issue closing the old connection just if there are no other streams connected (similarly on what we do Producer side)

Gsantomaggio commented 7 months ago

LGTM pair with @DanielePalaia