diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-01-03 14:43:38 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-01-03 14:43:38 +0000 |
| commit | fdc74c07d63ff897f42405b6dde0ffa46d6e26c3 (patch) | |
| tree | 771d685e9f1df797ac7862035b5c03e462b9fc17 /openstack/common/rpc/impl_kombu.py | |
| parent | ca21b092114eecff69ccc2903a13fa6d4b606761 (diff) | |
| parent | 77442689c676a7fb9ee5a277e498e8c3495346d9 (diff) | |
| download | oslo-fdc74c07d63ff897f42405b6dde0ffa46d6e26c3.tar.gz oslo-fdc74c07d63ff897f42405b6dde0ffa46d6e26c3.tar.xz oslo-fdc74c07d63ff897f42405b6dde0ffa46d6e26c3.zip | |
Merge "Add a rpc envelope format version number."
Diffstat (limited to 'openstack/common/rpc/impl_kombu.py')
| -rw-r--r-- | openstack/common/rpc/impl_kombu.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/openstack/common/rpc/impl_kombu.py b/openstack/common/rpc/impl_kombu.py index 668d9b6..96e81d7 100644 --- a/openstack/common/rpc/impl_kombu.py +++ b/openstack/common/rpc/impl_kombu.py @@ -162,7 +162,8 @@ class ConsumerBase(object): def _callback(raw_message): message = self.channel.message_to_python(raw_message) try: - callback(message.payload) + msg = rpc_common.deserialize_msg(message.payload) + callback(msg) message.ack() except Exception: LOG.exception(_("Failed to process message... skipping it.")) |