From 8a3744fe055843ecf5a7208ea32fb42e6c4224b1 Mon Sep 17 00:00:00 2001
From: Xavier Queralt <xqueralt@redhat.com>
Date: Wed, 19 Feb 2014 11:56:02 +0100
Subject: [PATCH] Pass the session to QpidMessage constructor
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
---
oslo/messaging/_drivers/impl_qpid.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/oslo/messaging/_drivers/impl_qpid.py b/oslo/messaging/_drivers/impl_qpid.py
index 4ebfa60e4..b85bfff44 100644
--- a/oslo/messaging/_drivers/impl_qpid.py
+++ b/oslo/messaging/_drivers/impl_qpid.py
@@ -194,7 +194,7 @@ class ConsumerBase(object):
message = self.receiver.fetch()
try:
self._unpack_json_msg(message)
- self.callback(QpidMessage(message))
+ self.callback(QpidMessage(self.session, message))
except Exception:
LOG.exception(_("Failed to process message... skipping it."))
self.session.acknowledge(message)