openstack/oslo.messaging
Code Issues Proposed changes

Merge "Oslo-messaging-zmq-receiver cannot recive any messages"

Browse Source
This commit is contained in:
Jenkins 2014-04-04 20:21:21 +00:00 committed by Gerrit Code Review
commit 01c347ea24
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
oslo/messaging/_drivers/impl_zmq.py
View File

@ -230,7 +230,7 @@ class ZmqClient(object):
(msg_id, topic, 'cast', _serialize(data)))) (msg_id, topic, 'cast', _serialize(data))))
return return
rpc_envelope = rpc_common.serialize_msg(data[1], envelope) rpc_envelope = rpc_common.serialize_msg(data[1])
zmq_msg = moves.reduce(lambda x, y: x + y, rpc_envelope.items()) zmq_msg = moves.reduce(lambda x, y: x + y, rpc_envelope.items())
self.outq.send(map(bytes, self.outq.send(map(bytes,
(msg_id, topic, 'impl_zmq_v2', data[0]) + zmq_msg)) (msg_id, topic, 'impl_zmq_v2', data[0]) + zmq_msg))