|
|
@@ -216,7 +216,6 @@ class RabbitMQ:
|
|
|
"""
|
|
|
data_lst = data if isinstance(data, list) else [data]
|
|
|
for item in data_lst:
|
|
|
- log.debug(f"【{queue}】Mq Push >>> {item}")
|
|
|
data_bytes = tools.dumps_obj(item) # 对象序列化
|
|
|
# RabbitMQ 的 delivery_mode 属性用于设置消息的持久性。它有两种取值：
|
|
|
# delivery_mode=1：表示消息被标记为持久化，但是仍然可能在服务器重启之前丢失。
|
|
|
@@ -347,7 +346,6 @@ class RabbitMQ:
|
|
|
body = message.body
|
|
|
# 处理接收到的消息
|
|
|
impl = tools.loads_obj(body)
|
|
|
- log.debug(f"【{queue}】Mq Received>>> {impl}")
|
|
|
delivery_tag = message.delivery_tag
|
|
|
if no_ack:
|
|
|
self._channel.basic.ack(delivery_tag)
|
|
|
@@ -388,7 +386,6 @@ class RabbitMQ:
|
|
|
body = message.body
|
|
|
# 处理接收到的消息
|
|
|
impl = tools.loads_obj(body)
|
|
|
- log.debug(f"【{queue}】Mq Received>>> {impl}")
|
|
|
delivery_tag = message.delivery_tag
|
|
|
if feature in impl:
|
|
|
if no_ack:
|
