Added support for redis streams. This also introduces the consumer class. This can be used to consume and process messages from a stream. Subscribing to a stream first tries to consume pending messages in the case of a crash. If there are no pending messages or all have been consumed, the consumer will process new messages.
Check out the official streams intro to learn more about redis streams.
Added support for redis streams. This also introduces the consumer class. This can be used to consume and process messages from a stream. Subscribing to a stream first tries to consume pending messages in the case of a crash. If there are no pending messages or all have been consumed, the consumer will process new messages.
Check out the official streams intro to learn more about redis streams.