def connect(self):
        """
        Connects to RabbitMQ
        """
        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()
Connects to RabbitMQ