celery_app.py

exchange = Exchange(CONSUMER_EXCHANGE, type='direct')
lookout_queue = Queue('lookout_rep', exchange, CONSUMER_QUEUE_ROUTING_KEY)

class LookoutConsumerStep(bootsteps.ConsumerStep):
    def get_consumers(self, channel):
        return [Consumer(channel, queues=[lookout_queue], callbacks=[self.handle_message], accept=['json'])]

    def handle_message(self, body, message):
        from DNotify.logic.replication import handle_replication_message
        
        handle_replication_message(message=body)
        message.ack()