Module svc_compliance::amqp

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_FLIGHTPLAN
  Name of the AMQP exchange for flightplan messages
• QUEUE_NAME_CARGO
  Name of the AMQP queue for CARGO messages
• ROUTING_KEY_CARGO
  Routing key for CARGO messages

Functions

• init_mq
  Initializes the AMQP connection. Creates the flightplan exchange and queues.