Remove accidental use of messaging.rpc_server
Hmm, maybe this means we should use __all__ to avoid exporting these imports.
This commit is contained in:
parent
5cd662a517
commit
2f4d53921f
@ -19,9 +19,9 @@ class Server(object):
|
||||
self.target = messaging.Target(topic='testtopic',
|
||||
server=transport.conf.host,
|
||||
version='2.5')
|
||||
self._server = messaging.rpc_server.get_rpc_server(transport,
|
||||
self.target,
|
||||
[self])
|
||||
self._server = messaging.get_rpc_server(transport,
|
||||
self.target,
|
||||
[self])
|
||||
super(Server, self).__init__()
|
||||
|
||||
def start(self):
|
||||
|
@ -23,10 +23,10 @@ class Server(object):
|
||||
self.target = messaging.Target(topic='testtopic',
|
||||
server=transport.conf.host,
|
||||
version='2.5')
|
||||
self._server = messaging.rpc_server.get_rpc_server(transport,
|
||||
self.target,
|
||||
[self],
|
||||
executor='eventlet')
|
||||
self._server = messaging.get_rpc_server(transport,
|
||||
self.target,
|
||||
[self],
|
||||
executor='eventlet')
|
||||
super(Server, self).__init__()
|
||||
|
||||
def start(self):
|
||||
|
Loading…
Reference in New Issue
Block a user