Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

NOISSUE - Add Event Subscriber Config #2054

Merged
merged 3 commits into from
Feb 26, 2024

Conversation

rodneyosodo
Copy link
Member

What type of PR is this?

This is a refactor PR as it add event subscriber option when consuming messages

What does this do?

This PR adds an event subscriber which combines stream, consumer and handler to a single struct to the codebase. The code is related to event handling, subscribing to event stores, and using message brokers like RabbitMQ, Redis, and NATS. Instead of passing consumer and stream at initializing the subscriber, we pass then when subscribing to the event

Which issue(s) does this PR fix/relate to?

  • Related Issue absmach/magistrala-ui-new#164
  • Resolves #

Have you included tests for your changes?

Yes, I have included tests for my changes.

Did you document any new/modified feature?

Added godocs

Notes

@rodneyosodo rodneyosodo force-pushed the events-refactor branch 7 times, most recently from f7e045d to ec560a0 Compare January 15, 2024 10:43
@rodneyosodo rodneyosodo force-pushed the events-refactor branch 3 times, most recently from 2bb4b1a to a33e439 Compare January 30, 2024 11:22
@rodneyosodo rodneyosodo force-pushed the events-refactor branch 2 times, most recently from 299e53b to f81067c Compare February 12, 2024 19:51
@rodneyosodo rodneyosodo force-pushed the events-refactor branch 3 times, most recently from c5b65ee to 3bed0ba Compare February 23, 2024 12:12
This commit adds event subscriber which combines stream, consumer and handler to a single struct to the codebase. The code is related to event handling, subscribing to event stores, and using message brokers like RabbitMQ, Redis, and NATS.

Signed-off-by: Rodney Osodo <[email protected]>
The code changes involve updating the "thingsStream" variable and modifying configurations and log messages in multiple files across different directories and packages. The changes include adding "events." to the stream name, updating topic names, and modifying log messages for handling NATS and RabbitMQ events.

Signed-off-by: Rodney Osodo <[email protected]>
Signed-off-by: Rodney Osodo <[email protected]>
@dborovcanin dborovcanin merged commit adb03b4 into absmach:main Feb 26, 2024
5 checks passed
@rodneyosodo rodneyosodo deleted the events-refactor branch February 26, 2024 16:46
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants