notifications_consumer

class NotificationsConsumer(rabbitmq_config)[source]

Bases: pyloggr.rabbitmq.consumer.Consumer, pyloggr.utils.observable.Observable

Consumes notification that were posted in RabbitMQ

Parameters:
  • rabbitmq_config (pyloggr.config.RabbitMQBaseConfig) – RabbitMQ connection parameters (to consume notifications from RabbitMQ)
  • binding_key (str) – Binding key to filter notifications
start_consuming(*args, **kwargs)[source]

Start consuming notifications from RabbitMQ and notify observers.