Repository navigation
[Feat]: Regarding the implementation method of the abstract method in queue_manager #86
Description
Is your feature request related to a problem? Please describe.
- in_memory_queue_manager.py
InMemoryQueueManageruses 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
Activity
kthota-g commentedon Jun 20, 2025
Currently the SDK only has InMemory implementations for various stores. Support for persistent DB backed storage is in the works here - #164 and queue manager is also another component that requires persistent storage implementations.
Please feel free to contribute to the PR if you are interested in adding this support to queue manager.