-
Notifications
You must be signed in to change notification settings - Fork 11
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
Refactor Message Queue implementation #64
Refactor Message Queue implementation #64
Conversation
7f0dd69
to
27e1046
Compare
bea2dba
to
2b32952
Compare
45df65e
to
f77764b
Compare
f77764b
to
4bd1afa
Compare
7d94a37
to
468dad8
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for this refactoring @terryyylim ! The PR largely looks good. Left some comments on the organization of the code.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM! Thanks a lot for the extensive refactoring! Just left a couple of tiny comments! 🚀
eab9be0
to
d79b24e
Compare
d79b24e
to
9fcc4db
Compare
What this PR does / why we need it:
In order for Management and Treatment Service to start without an actual Google PubSub, we need to remove the dependency on it, and this PR introduces a generic
MessageQueue
interface for doing so.In addition, an enum has been introduced for the schema used by Treatment Service plugin, to support
noop
andpubsub
message queue kinds.Which issue(s) this PR fixes:
Fixes #