diff options
Diffstat (limited to 'openstack/common/rpc')
| -rw-r--r-- | openstack/common/rpc/service.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/openstack/common/rpc/service.py b/openstack/common/rpc/service.py index e572956..6b56ebb 100644 --- a/openstack/common/rpc/service.py +++ b/openstack/common/rpc/service.py @@ -57,6 +57,11 @@ class Service(service.Service): self.conn.create_consumer(self.topic, dispatcher, fanout=True) + # Hook to allow the manager to do other initializations after + # the rpc connection is created. + if callable(getattr(self.manager, 'initialize_service_hook', None)): + self.manager.initialize_service_hook(self) + # Consume from all consumers in a thread self.conn.consume_in_thread() |