openstack
/
oslo.messaging
Code Issues Proposed changes

Merge "Fix error in example of an RPC server"

This commit is contained in:
Jenkins 2014-08-19 19:17:18 +00:00 committed by Gerrit Code Review
parent 84b36f06ca ba5b547652
commit 1ee33509e7
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
oslo/messaging/rpc/server.py
View File

@ -54,6 +54,7 @@ A simple example of an RPC server with multiple endpoints might be::
self.server = server
def stop(self, ctx):
if server:
self.server.stop()
class TestEndpoint(object):
@ -64,7 +65,7 @@ A simple example of an RPC server with multiple endpoints might be::
transport = messaging.get_transport(cfg.CONF)
target = messaging.Target(topic='test', server='server1')
endpoints = [
ServerControlEndpoint(self),
ServerControlEndpoint(None),
TestEndpoint(),
]
server = messaging.get_rpc_server(transport, target, endpoints,