openstack/oslo.messaging
Code Issues Proposed changes

Merge "[zmq] Fix backend router port for proxy."

Browse Source
This commit is contained in:
Jenkins 2016-06-15 23:39:19 +00:00 committed by Gerrit Code Review
commit f3894c879f
1 changed files with 4 additions and 4 deletions

8
oslo_messaging/_drivers/zmq_driver/broker/zmq_queue_proxy.py

@ -51,7 +51,7 @@ class UniversalQueueProxy(object):
self.fe_router_address = zmq_address.combine_address( self.fe_router_address = zmq_address.combine_address(
self.conf.rpc_zmq_host, self.fe_router_socket.port) self.conf.rpc_zmq_host, self.fe_router_socket.port)
self.be_router_address = zmq_address.combine_address( self.be_router_address = zmq_address.combine_address(
self.conf.rpc_zmq_host, self.fe_router_socket.port) self.conf.rpc_zmq_host, self.be_router_socket.port)
self.pub_publisher = zmq_pub_publisher.PubPublisherProxy( self.pub_publisher = zmq_pub_publisher.PubPublisherProxy(
conf, matchmaker) conf, matchmaker)
@ -70,9 +70,9 @@ class UniversalQueueProxy(object):
zmq_names.NOTIFY_TYPE): zmq_names.NOTIFY_TYPE):
self.pub_publisher.send_request(message) self.pub_publisher.send_request(message)
else: else:
self._redirect_message(self.be_router_socket self._redirect_message(self.be_router_socket.handle
if socket is self.fe_router_socket if socket is self.fe_router_socket.handle
else self.fe_router_socket, message) else self.fe_router_socket.handle, message)
@staticmethod @staticmethod
def _receive_in_request(socket): def _receive_in_request(socket):