code: def connect(self):
          
          self.connection = Connection(self.broker_url)
  
          e = Exchange('mease', type='fanout', durable=False, delivery_mode=1)
          self.exchange = e(self.connection.default_channel)
          self.exchange.declare()
docs: Connects to RabbitMQ