Reference

idm_broker.apps (notifications for model changes)

class idm_broker.apps.IDMBrokerConfig(*args, **kwargs)

name = 'idm_broker'

ready()

register_notification(*, serializer: rest_framework.serializers.BaseSerializer, exchange, model=None, renderer: rest_framework.renderers.BaseRenderer = <class 'rest_framework.renderers.JSONRenderer'>)

register_notifications(registrations)

register_related_notification(model, accessor)

idm_broker.consumer (consuming tasks into celery tasks)

class idm_broker.consumer.BrokerTaskConsumer

A kombu kombu.mixins.ConsumerMixin that consumes from queues declared in settings.IDM_BROKER['CONSUMERS'], and dispatches each message received to one or more configured celery tasks.

classmethod get_callback(task_name)

get_consumers(Consumer, channel)

on_consume_ready(connection, channel, consumers, **kwargs)

ready = None

run(_tokens=1, **kwargs)