Replies: 1 comment
-
Why would you call that inefficient? |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
Hello, I would like to apply redis streams.
I'm going to make one consumer into one goroutine.
One consumer repeatedly reads the message to the
xreadgroup
through the for statement.At this time, I would like to use the
xautoclaim
command to process messages that are pending for a certain period of time.The percentage of messages in the pending state will be very low, but simply calling xreadgroup and xautoclaim alternately seems inefficient as shown below..
Should there be other objects running xautoclaim periodically?
Or is there any way?
Beta Was this translation helpful? Give feedback.
All reactions