anderson-ufrj
feat: implement WebSocket message batching and async queue system
1762def
"""Messaging infrastructure for Cidadão.AI."""
from .queue_service import (
Task,
TaskStatus,
TaskPriority,
TaskHandler,
QueueService,
InvestigationTaskHandler,
get_queue_service
)
__all__ = [
"Task",
"TaskStatus",
"TaskPriority",
"TaskHandler",
"QueueService",
"InvestigationTaskHandler",
"get_queue_service"
]