Skip to content

[Feat]: Regarding the implementation method of the abstract method in queue_manager #86

@Linux2010

Description

@Linux2010

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

Metadata

Metadata

Assignees

Labels

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions