openstack/oslo.messaging
Code Issues Proposed changes

Pass the session to QpidMessage constructor

Browse Source 
The patch in I6e37780cc28737cfd56b6719ec8d9cebbc9bb278 added a new class
for the QpidMessage which was wrongly initialized when processing a
message.

Change-Id: Iaf525fc6ee9e56100c89863f9c651f20c148ecb5
Closes-Bug: 1282038
This commit is contained in:
Xavier Queralt 2014-02-19 11:56:02 +01:00
parent e785a5d994
commit 8a3744fe05
1 changed files with 1 additions and 1 deletions

2
oslo/messaging/_drivers/impl_qpid.py

@ -194,7 +194,7 @@ class ConsumerBase(object):
message = self.receiver.fetch() message = self.receiver.fetch()
try: try:
self._unpack_json_msg(message) self._unpack_json_msg(message)
self.callback(QpidMessage(message)) self.callback(QpidMessage(self.session, message))
except Exception: except Exception:
LOG.exception(_("Failed to process message... skipping it.")) LOG.exception(_("Failed to process message... skipping it."))
self.session.acknowledge(message) self.session.acknowledge(message)