消费

Author: liu kelin

python_sync_nosql/__pycache__/queue_rabbitmq.cpython-35.pyc

@@ -35,9 +35,11 @@ def consumer_data():
 def callback(ch, method, properties, body):
 
 # set data
-ack = sync_data.set_data(body)
+ack = sync_data.set_data(body) 
+
+# ACK 确认
+ch.basic_ack(delivery_tag = method.delivery_tag)
 
- ch.basic_ack(delivery_tag = method.delivery_tag) # ACK 确认
 
 
 channel.basic_qos(prefetch_count=1) # 允许暂留Unacked数量，（数据未basic_ack前 数据保存在Unacked允许的最大值）

python_sync_nosql/__pycache__/sync_redis.cpython-35.pyc

@@ -14,4 +14,4 @@
 
 print(' ====liukelin==== ')
 print(' [*] Waiting for messages. To exit press CTRL+C')
-get_rabbitmq.consumer_data()
+queue_rabbitmq.consumer_data()