diff options
| author | Devananda van der Veen <devananda.vdv@gmail.com> | 2013-07-18 15:35:44 -0700 |
|---|---|---|
| committer | Devananda van der Veen <devananda.vdv@gmail.com> | 2013-07-18 15:36:19 -0700 |
| commit | f52446cbe291e8c8f603ddb39acb950b72195884 (patch) | |
| tree | 9af13d967fe3ff67c00c5e6d1deca0a8ff8f5a29 /openstack | |
| parent | 0ae9ebb507d4e73e575d64095ca6e0ccd5de1225 (diff) | |
| download | oslo-f52446cbe291e8c8f603ddb39acb950b72195884.tar.gz oslo-f52446cbe291e8c8f603ddb39acb950b72195884.tar.xz oslo-f52446cbe291e8c8f603ddb39acb950b72195884.zip | |
Add serializer param to RPC service
Allow a serializer to be passed to RPC service class
when it is instantiated.
Change-Id: I85dafc392023f0ae845efe851a5a4a9438e40e37
Diffstat (limited to 'openstack')
| -rw-r--r-- | openstack/common/rpc/service.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/openstack/common/rpc/service.py b/openstack/common/rpc/service.py index e60cd1f..f44f0ad 100644 --- a/openstack/common/rpc/service.py +++ b/openstack/common/rpc/service.py @@ -32,10 +32,11 @@ class Service(service.Service): A service enables rpc by listening to queues based on topic and host. """ - def __init__(self, host, topic, manager=None): + def __init__(self, host, topic, manager=None, serializer=None): super(Service, self).__init__() self.host = host self.topic = topic + self.serializer = serializer if manager is None: self.manager = self else: @@ -48,7 +49,8 @@ class Service(service.Service): LOG.debug(_("Creating Consumer connection for Service %s") % self.topic) - dispatcher = rpc_dispatcher.RpcDispatcher([self.manager]) + dispatcher = rpc_dispatcher.RpcDispatcher([self.manager], + self.serializer) # Share this same connection for these Consumers self.conn.create_consumer(self.topic, dispatcher, fanout=False) |