Skip to content

Replace redis_client with AbstractMessageQueue in EventDispatcher, EventProducer. #3887

@HyeockJinKim

Description

@HyeockJinKim

Motivation  

  • To support both message queues seamlessly, the redis_client needs to be replaced to an abstract message queue which can support both kafka and redis_client

Required Features

  • Add the kafka service to docker-compose file
  • Implement an abstract class for the abstract message queue
  • Modify the EventDispatcher and EventProducer accordingly

Impact  

  • Affects events.py under common and the docker-compose file

Testing Scenarios  

  • Test the message queue feature

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions