search

Observation-Management-Service / MQClient

A Message Queue Client API Supporting Apache Pulsar, RabbitMQ, and NATS.io
MIT License
0 stars 1 forks source link

Prefetch Updates: `open_sub_manual_acking()` #104

Closed ric-evans closed 1 year ago

ric-evans commented 1 year ago

Add special logic for rabbitmq to get around its prefetch limits (https://www.rabbitmq.com/consumer-prefetch.html). Removes the use_prefetch_value arg from open_sub_manual_acking(): see https://github.com/Observation-Management-Service/MQClient/blob/v2.3.1/mqclient/queue.py#L322-L327

ric-evans commented 1 year ago

~TODO: need tests for retries--will closing the channel affect future acks from the old channel?~

update: tests made, differs by broker

ric-evans commented 1 year ago

~TODO: shuffle acks~

done!