code: def get_event_exchange(service_name):
      
      exchange_name = "{}.events".format(service_name)
      exchange = Exchange(
          exchange_name, type='topic', durable=True, delivery_mode=PERSISTENT
      )
  
      return exchange
docs: Get an exchange for ``service_name`` events.