mirror of
https://github.com/jhd3197/ServerKit.git
synced 2026-11-02 18:17:11 +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
15 lines
346 B
Python
15 lines
346 B
Python
"""Internal consumers for the ServerKit Queue Bus."""
|
|
from app.queue_bus.consumers.webhook_consumer import (
|
|
WebhookConsumer,
|
|
start_webhook_consumer,
|
|
stop_webhook_consumer,
|
|
enqueue_webhook_delivery,
|
|
)
|
|
|
|
__all__ = [
|
|
'WebhookConsumer',
|
|
'start_webhook_consumer',
|
|
'stop_webhook_consumer',
|
|
'enqueue_webhook_delivery',
|
|
]
|