diff --git a/neutron/service.py b/neutron/service.py index 29d47ae2f41..f31f44c01c2 100644 --- a/neutron/service.py +++ b/neutron/service.py @@ -89,7 +89,7 @@ def serve_wsgi(cls): LOG.exception('Unrecoverable error: please check log ' 'for details.') - registry.notify(resources.PROCESS, events.BEFORE_SPAWN, service) + registry.publish(resources.PROCESS, events.BEFORE_SPAWN, service) return service @@ -262,7 +262,7 @@ def _start_workers(workers): def start_all_workers(): workers = _get_rpc_workers() + _get_plugins_workers() launcher = _start_workers(workers) - registry.notify(resources.PROCESS, events.AFTER_SPAWN, None) + registry.publish(resources.PROCESS, events.AFTER_SPAWN, None) return launcher diff --git a/neutron/tests/unit/test_service.py b/neutron/tests/unit/test_service.py index fb700400b28..de5c3507baa 100644 --- a/neutron/tests/unit/test_service.py +++ b/neutron/tests/unit/test_service.py @@ -69,4 +69,4 @@ class TestRunWsgiApp(base.BaseTestCase): registry.subscribe(callback, resources.PROCESS, events.AFTER_SPAWN) service.start_all_workers() callback.assert_called_once_with( - resources.PROCESS, events.AFTER_SPAWN, mock.ANY) + resources.PROCESS, events.AFTER_SPAWN, mock.ANY, payload=None)