diff options
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) |