Tags: kak-tus/ami
Tags
- Update vendored redis to 6.15.2.
- Add error processing with optional ErrorNotifier interface.
- Use multiple ids in single command to do ACK.
- Use XDel from updated Redis package.
- Ack and produce in goroutines.
- Set big read/write timeouts to Redis client in examples and in docs to
allow sending data to Redis in time and to avoid retransmissions.
- Use "real" pipe period. In previous versions - we wait new message to check
period, so, old messages can wait a long time in buffer, if there are no
new messages.
- Switch from dep to go modules.
Fix infinite blocking of consumer in case of no messages. If user not set Block value in consumer and there is no messages in queue - consumer will block infinitely at Close() func, because we send BLOCK timeout = 0 to XREADGROUP Redis command and it will wait infinitely.
- Fix possible consumer stop. - Speedup ACK and producing.
PreviousNext