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()
评论列表
文章目录