Observation-Management-Service / MQClient

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

Remove `ack_timeout` [minor] #107

Closed ric-evans closed 1 year ago

ric-evans commented 1 year ago

RabbitMQ: The heartbeat timeout value is not the same as the ack timeout--this PR divorces the two and relies solely on the broker's values. The ack timeout (the broker's consumer_timeout) is not configurable nor retrievable from the client.

Pulsar: The ack timeout is now (again) set using PULSAR_UNACKED_MESSAGES_TIMEOUT_SEC

Nats: Doesn't use ack timeouts