def wait_int_message(self, dont_wait=True):
if dont_wait:
# wait for internal message
try:
msg = self.list_communication_channel.recv(zmq.DONTWAIT)
return msg
except zmq.Again:
raise zmq.Again
else:
self.logger.debug('waiting for a request')
msg = self.list_communication_channel.recv()
return msg
评论列表
文章目录