openstack/oslo.messaging
Code Issues Proposed changes

Use inferred=True by default

Browse Source 
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
This commit is contained in:
Flavio Percoco 2015-06-15 13:48:27 +02:00
parent f06b19628f
commit c8845b4bef
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
oslo_messaging/_drivers/protocols/amqp/driver.py
View File

@ -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 = {