Skip to content

bovine_propan.exchanges

processed = RabbitExchange('processed', auto_delete=False, type=(ExchangeType.TOPIC)) module-attribute

Exchange used for messages having been processed, currently used to feed the EventSources

processing = RabbitExchange('processing', auto_delete=False, type=(ExchangeType.TOPIC)) module-attribute

Exchange used for messages being processed.

Relevant routing_key are:

  • inbox
  • outbox