def call(self, n):
self.response = None
self.corr_id = str(uuid.uuid4())
basicProperties = pika.BasicProperties(
reply_to=self.callback_queue,
correlation_id=self.corr_id,
)
self.channel.basic_publish(exchange='',
routing_key=QUEUE,
properties=basicProperties,
body=str(n))
while self.response is None:
self.connection.process_data_events()
return self.response
评论列表
文章目录