Module svc_telemetry::amqp

source ·
Expand description

provides AMQP/RabbitMQ implementations for queuing layer

Modules

macros
log macro’s for REST logging
pool
AMQP connection pool implementation

Structs

AMQPChannel
Wrapper struct to allow unit testing on un-connected amqp_channel

Enums

AMQPError
Custom Error type for MQ errors

Constants

EXCHANGE_NAME_TELEMETRY
Name of the AMQP exchange for telemetry messages
QUEUE_NAME_ADSB
Name of the AMQP queue for ADSB messages
ROUTING_KEY_ADSB
Routing key for ADSB messages

Functions

init_mq
Initializes the AMQP connection. Creates the telemetry exchange and queues.