Changeset 972 for trunk/Monitoring
- Timestamp:
- 11/22/13 23:19:15 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/Monitoring/Watch/watch
r966 r972 321 321 Actions.execActions(message) 322 322 323 324 self.channel.basic_ack(delivery_tag = method.delivery_tag) # "msg acknowledgment" stuff 325 326 323 327 except Exception,e: 324 328 logger.exception("ERR019 - exception occurs") … … 334 338 self.channel.queue_declare(queue='myqueue',durable=True) 335 339 336 self.channel.basic_consume(callback, queue='myqueue' , no_ack=True)340 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) 337 341 338 342 self.channel.start_consuming()
Note: See TracChangeset
for help on using the changeset viewer.