Part of parent story #41.
馃幆 Goal
Implement asynchronous queue dispatching and concurrent worker listeners for high-frequency sensor frame ingestion.
馃搵 Specification
- Configure
@quatrain/queue-amqp:
- Register
AmqpQueueAdapter via Queue.addQueue(rabbitQueue, 'amqp', true).
- Setup auto-reconnection and channel recovery parameters.
- Ingestion Controller:
- Receive HTTP webhook payloads from LoRaWAN network server (ChirpStack) or cellular gateway.
- Enqueue frames instantly onto RabbitMQ topic
'sensor-frames' with sub-10ms response time.
- Background Worker:
- Worker listener with
queue.listen('sensor-frames', handler, { concurrency: 10 }).
- Parse payloads, persist metrics, and evaluate alert triggers.
- Protect ingestion endpoints against flooding using
@quatrain/auth-rbac TarpitManager.
Part of parent story #41.
馃幆 Goal
Implement asynchronous queue dispatching and concurrent worker listeners for high-frequency sensor frame ingestion.
馃搵 Specification
@quatrain/queue-amqp:AmqpQueueAdapterviaQueue.addQueue(rabbitQueue, 'amqp', true).'sensor-frames'with sub-10ms response time.queue.listen('sensor-frames', handler, { concurrency: 10 }).@quatrain/auth-rbacTarpitManager.