diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-07-23 13:26:45 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-07-23 13:26:45 +0000 |
| commit | 4edb228f8d0e36454fdd54f6bbc7661919845033 (patch) | |
| tree | a220d5e2efabfed9e06e63e9a153bdbc1b69ff12 /openstack | |
| parent | d5ffda101a65158a1ceb6bf633542a44abdd9fdf (diff) | |
| parent | f52446cbe291e8c8f603ddb39acb950b72195884 (diff) | |
| download | oslo-4edb228f8d0e36454fdd54f6bbc7661919845033.tar.gz oslo-4edb228f8d0e36454fdd54f6bbc7661919845033.tar.xz oslo-4edb228f8d0e36454fdd54f6bbc7661919845033.zip | |
Merge "Add serializer param to RPC service"
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) |