search

adjust / rmq

Message queue system written in Go and backed by Redis
MIT License
1.57k stars 206 forks source link

Fix connections unack messages to be equal to prefetchLimit #86

Closed nehaboob closed 4 years ago

nehaboob commented 4 years ago

Currently connection is taking prefetchLimit number of messages in delivery chain hence connection holds more than prefetchLimit of messages unacknowledged at any time. Because number of messages unack by connection at any time = messages in consumption + messages waiting in delivery channel.

This commit is to make connections unack messages equal to prefetchLimit.

Changing the test cases according to the new change.