From f52446cbe291e8c8f603ddb39acb950b72195884 Mon Sep 17 00:00:00 2001 From: Devananda van der Veen Date: Thu, 18 Jul 2013 15:35:44 -0700 Subject: Add serializer param to RPC service Allow a serializer to be passed to RPC service class when it is instantiated. Change-Id: I85dafc392023f0ae845efe851a5a4a9438e40e37 --- openstack/common/rpc/service.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'openstack') 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) -- cgit