test12.py 文件源码

def receive(self,username,pwd,ip,port):#????????????????????????
        user_pwd = pika.PlainCredentials(username, pwd)
        s_conn = pika.BlockingConnection(pika.ConnectionParameters(ip,port,'/', credentials=user_pwd))
        channel = s_conn.channel()
        channel.queue_declare(queue='city_task_queue', durable=True)
        channel.basic_qos(prefetch_count=1)
        print '???????????'
        channel.basic_consume(self.callback,
                              queue='city_task_queue',
                              )
        channel.start_consuming()