|
@@ -324,7 +324,7 @@ class BaseBusinessDetailSpider(Spider):
|
|
|
tools.delay_time(0.8) # 监听与收复消息的时间间隔
|
|
tools.delay_time(0.8) # 监听与收复消息的时间间隔
|
|
|
inbound = channel.build_inbound_messages(break_on_empty=True)
|
|
inbound = channel.build_inbound_messages(break_on_empty=True)
|
|
|
message_dict = {msg.correlation_id: msg for msg in inbound}
|
|
message_dict = {msg.correlation_id: msg for msg in inbound}
|
|
|
- log.debug(f"采集任务推送 {message_dict}")
|
|
|
|
|
|
|
+ # log.debug(f"采集任务推送 {message_dict}")
|
|
|
message = message_dict.get(correlation_id)
|
|
message = message_dict.get(correlation_id)
|
|
|
if message:
|
|
if message:
|
|
|
body = tools.loads_obj(message.body)
|
|
body = tools.loads_obj(message.body)
|
