(....)

    def __init__(self):
        self.domains = []

        try:
            self.CONN = MySQLdb.connect(host=SQL_HOST,
                                        user=SQL_USER,
                                        passwd=SQL_PASSWD,
                                        db=SQL_DB)
        except MySQLdb.Error, e:
            print "Error %d: %s" % (e.args[0], e.args[1])
            sys.exit(1)

        self.cursor = self.CONN.cursor()
        self.connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
        self.channel = self.connection.channel()
        self.channel.queue_declare(queue='expired', passive=False, durable=True, auto_delete=False)
        self.channel.basic_qos(prefetch_count=1)
        self.channel.basic_consume(self.callback, queue='expired')
        logging.warning('Worker Start !')
        self.channel.start_consuming()


class Worker(multiprocessing.Process):
    def run(self):
        Analyse()


if __name__ == '__main__':
    jobs = []
    for i in range(3):
        p = Worker()
        jobs.append(p)
        p.daemon = False
        p.start()
    for j in jobs:
        j.join()