openstack/oslo.messaging
Code Issues Proposed changes

Merge "Fix message missing after duplicated message error"

Browse Source
This commit is contained in:
Jenkins 2015-08-19 18:15:45 +00:00 committed by Gerrit Code Review
commit 385a768900
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
oslo_messaging/_drivers/amqpdriver.py
View File

@ -102,8 +102,8 @@ class AMQPIncomingMessage(base.IncomingMessage):
self._send_reply(conn, ending=True)
def acknowledge(self):
self.listener.msg_id_cache.add(self.unique_id)
self.acknowledge_callback()
self.listener.msg_id_cache.add(self.unique_id)
def requeue(self):
# NOTE(sileht): In case of the connection is lost between receiving the