mirror of
https://github.com/jhd3197/ServerKit.git
synced 2026-10-30 08:36:55 +09:00
Juan Denis
9b4618b24b
- Add pluggable queue bus with SQLAlchemy backend (Redis-ready interface) - Models: QueueGroup, Queue, QueueMessage with retries, visibility timeout, delayed delivery, priority ordering, and dead-letter handling - REST API at /api/v1/queue for groups, queues, messages, and stats - Plugin SDK: from app.plugins_sdk import queue - Operations UI page with group/queue/message management and send-message form - Migrate webhook deliveries from raw threading.Thread to the queue bus - Add webhook consumer with retry/dead-letter support - Migration 022_queue_bus and backend tests
17 lines
359 B
Python
17 lines
359 B
Python
"""ServerKit Queue Bus.
|
|
|
|
A pluggable message queue bus for core services and extensions.
|
|
"""
|
|
|
|
from app.queue_bus.models import QueueGroup, Queue, QueueMessage
|
|
from app.queue_bus.service import QueueBusService
|
|
from app.queue_bus.sdk import QueueBusSdk
|
|
|
|
__all__ = [
|
|
'QueueGroup',
|
|
'Queue',
|
|
'QueueMessage',
|
|
'QueueBusService',
|
|
'QueueBusSdk',
|
|
]
|