Open
Description
Is your feature request related to a problem? Please describe.
- in_memory_queue_manager.py
InMemoryQueueManager
uses a dictionary_task_queue: dict[str, EventQueue]
to store the event queue for each task.- All data resides in memory without any persistence mechanism.
- Once the service restarts (or the process terminates), all in-memory data will be lost.
- Is there a plan to add implementation types for message queues, such as using local disk storage or message middleware?
Describe the solution you'd like
- For example, implementations based on general database (DB) protocols and message queue (MQ) protocols.
- db_memory_queue_manager.py
- mq_memory_queue_manager.py
Describe alternatives you've considered
No response
Additional context
No response
Code of Conduct
- I agree to follow this project's Code of Conduct