diff options
| author | Flavio Percoco <flaper87@gmail.com> | 2015-06-15 13:48:27 +0200 |
|---|---|---|
| committer | Flavio Percoco <flaper87@gmail.com> | 2015-06-16 11:06:49 +0200 |
| commit | 20d406f4fe3a84a8c2c176926820532bcaa91a46 (patch) | |
| tree | fdc195dab8fff7d85e7c5946379fb4ea715a0f25 | |
| parent | 0f24108058fbf15752d384be4c13e4fbac801f2a (diff) | |
| download | oslo-messaging-20d406f4fe3a84a8c2c176926820532bcaa91a46.tar.gz | |
Use `inferred=True` by default
Rabbitmq's amqp1.0 plugin doesn't have support for vbin8, which is the
default encoding used by qpid-proton. In order to workaround this issue
we should use inferred=True.
Closes-bug: #1465409
Change-Id: Id265917244d7e152c5e13a10df367a3e59de8e50
(cherry picked from commit c8845b4bef4248fad4a9da8dad0455495b2bc6fd)
| -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 ba27f0c..5b4564f 100644 --- a/oslo_messaging/_drivers/protocols/amqp/driver.py +++ b/oslo_messaging/_drivers/protocols/amqp/driver.py @@ -108,7 +108,9 @@ class ReplyTask(controller.Task): 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} @@ -129,7 +131,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 = { |