skip to Main Content

Redis Stream I need Event Driven Architecture,

When any new message received in the stream, on that time OnMessageReceived event should trigger. public event EventHandler<MqMessageReceivedEventArgs> OnMessageReceived; var result = await redisDatabase.StreamRangeAsync(StreamName, "-", "+", 1, Order.Ascending); protected virtual void OnMessageReceivedEvent(MqMessageReceivedEventArgs e) { OnMessageReceived?.Invoke(this, e); }

VIEW QUESTION
Back To Top
Search