You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Just use XREADGROUP (redis-rs xread fn with a group option) and request IDs of ">". This will obviate the need to maintain entry ID repositories entirely. You must XACK after processing each request.
Each service should be responsible for creating a uniquely named group associated with each stream being processed. Each group only needs a single consumer. In this way, multiple services can potentially read from the same stream without consuming each other's messages.
Goal
Just use XREADGROUP (redis-rs xread fn with a group option) and request IDs of ">". This will obviate the need to maintain entry ID repositories entirely. You must XACK after processing each request.
Each service should be responsible for creating a uniquely named group associated with each stream being processed. Each group only needs a single consumer. In this way, multiple services can potentially read from the same stream without consuming each other's messages.
See the examples in redis-rs/redis-rs#319.
Services to update
The text was updated successfully, but these errors were encountered: