def __init__(self, connection, exchange_name, serializer=DEFAULT_SERIALIZER, connect_max_retries=DEFAULT_MAX_RETRIES):
        super(KombuEventSystem, self).__init__()
        self.connection = connection
        self.exchange_name = exchange_name
        self.exchange = kombu.Exchange(exchange_name, 'topic', durable=True)
        self.waiting_exchange = kombu.Exchange('%s_waiting' % exchange_name, 'direct', durable=True)
        self.retry_exchange = kombu.Exchange('%s_retry' % exchange_name, 'direct', durable=True)
        self.serializer = serializer
        self.connect_max_retries = connect_max_retries
        self._producers = {}
        self.consumers_by_queue = {}
dataset/ETHPy150Open deliveryhero/lymph/lymph/events/kombu.py/KombuEventSystem.__init__/original