Changeset 972 for trunk/Monitoring

Timestamp:

11/22/13 23:19:15 (10 years ago)

Author:

jripsl

Message:

• add message acknowledgement.

File:

• trunk/Monitoring/Watch/watch (modified) (2 diffs)

trunk/Monitoring/Watch/watch

@@ -321 +321 @@
                                 Actions.execActions(message)
 
+
+                                self.channel.basic_ack(delivery_tag = method.delivery_tag) # "msg acknowledgment" stuff
+
+
                         except Exception,e:
                                 logger.exception("ERR019 - exception occurs")
@@ -334 +338 @@
                 self.channel.queue_declare(queue='myqueue',durable=True)
 
-                self.channel.basic_consume(callback, queue='myqueue', no_ack=True)
+                self.channel.basic_consume(callback, queue='myqueue') # do not set "no_ack=True" anymore here so to enable "msg acknowledgment" (i.e. no_ack default is false)
 
                 self.channel.start_consuming()