diff options
| author | Jenkins <jenkins@review.openstack.org> | 2015-06-16 09:49:22 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2015-06-16 09:49:22 +0000 |
| commit | a3a3c3faa88b89e8d962e1bf543e069adec235d3 (patch) | |
| tree | 78f53cb220884a4c6263b62e9df37b6dd88cd4b9 | |
| parent | f3d70a923ded74cb839220cce402ced578efb1b9 (diff) | |
| parent | c8845b4bef4248fad4a9da8dad0455495b2bc6fd (diff) | |
| download | oslo-messaging-a3a3c3faa88b89e8d962e1bf543e069adec235d3.tar.gz | |
Merge "Use `inferred=True` by default"
| -rw-r--r-- | oslo_messaging/_drivers/protocols/amqp/driver.py | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/oslo_messaging/_drivers/protocols/amqp/driver.py b/oslo_messaging/_drivers/protocols/amqp/driver.py index 705a090..cf1c912 100644 --- a/oslo_messaging/_drivers/protocols/amqp/driver.py +++ b/oslo_messaging/_drivers/protocols/amqp/driver.py @@ -46,7 +46,9 @@ LOG = logging.getLogger(__name__) def marshal_response(reply=None, failure=None): # TODO(grs): do replies have a context? - msg = proton.Message() + # NOTE(flaper87): Set inferred to True since rabbitmq-amqp-1.0 doesn't + # have support for vbin8. + msg = proton.Message(inferred=True) if failure: failure = common.serialize_remote_exception(failure) data = {"failure": failure} @@ -67,7 +69,9 @@ def unmarshal_response(message, allowed): def marshal_request(request, context, envelope): - msg = proton.Message() + # NOTE(flaper87): Set inferred to True since rabbitmq-amqp-1.0 doesn't + # have support for vbin8. + msg = proton.Message(inferred=True) if envelope: request = common.serialize_msg(request) data = { |