openstack
/
oslo.messaging
Code Issues Proposed changes

Update changes.txt for recent API changes

This commit is contained in:
Mark McLoughlin 2013-05-10 12:06:20 +01:00
parent 2405fd2619
commit e14ddb80e5
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
openstack/common/messaging/changes.txt
View File

@ -44,21 +44,26 @@ Projects will need to do e.g.
from nova import baserpc
from nova import config
from nova.openstack.common.messaging.rpc import server as rpcserver
from nova.openstack.common.messaging import server
from nova.openstack.common.messaging.executors import impl_eventlet
from nova.openstack.common.messaging.rpc import dispatcher
from nova.openstack.common.messaging.rpc import target
def start(self):
...
target = target.Target(topic=self.topic, self.host)
target = target.Target(topic=self.topic, self.server)
base_rpc = baserpc.BaseRPCAPI(self.service_name, backdoor_port)
self.rpcserver = rpcserver.EventletRPCServer(config.TRANSPORT_DRIVER,
target,
[self.manager, base_rpc])
self.rpcdispatcher = dispatcher.RPCDispatcher([self.manager, base_rpc])
LOG.debug(_("Starting RPC server for %(topic)s on %(host)s") %
dict(topic=self.topic, host=self.host))
self.rpcserver = server.MessageHandlingServer(config.TRANSPORT_DRIVER,
target,
self.rpcdispatcher,
impl_eventlet.EventletExecutor)
LOG.debug(_("Starting RPC server for %(topic)s on %(server)s") %
dict(topic=self.topic, host=self.server))
self.rpcserver.start()