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)