openstack/ironic
Code Issues Proposed changes

Use oslo.messaging serializers

Browse Source 
There are JsonPayloadSerializer and RequestContextSerializer
serializers so there is a sense to re-use them in Ironic.

Change-Id: Ie8d46365a6b1d1e89b3781fa26889d2a31f7afbe
This commit is contained in:
Victor Sergeyev 2015-06-03 17:30:13 +03:00
parent 9a72922ff7
commit 02f483887e
1 changed files with 2 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
ironic/common/rpc.py
View File

@ -15,7 +15,6 @@
from oslo_config import cfg
import oslo_messaging as messaging
from oslo_serialization import jsonutils
from ironic.common import context as ironic_context
from ironic.common import exception
@ -48,7 +47,7 @@ def init(conf):
TRANSPORT = messaging.get_transport(conf,
allowed_remote_exmods=exmods,
aliases=TRANSPORT_ALIASES)
serializer = RequestContextSerializer(JsonPayloadSerializer())
serializer = RequestContextSerializer(messaging.JsonPayloadSerializer())
NOTIFIER = messaging.Notifier(TRANSPORT, serializer=serializer)
@ -76,30 +75,7 @@ def get_allowed_exmods():
return ALLOWED_EXMODS + EXTRA_EXMODS
class JsonPayloadSerializer(messaging.NoOpSerializer):
@staticmethod
def serialize_entity(context, entity):
return jsonutils.to_primitive(entity, convert_instances=True)
class RequestContextSerializer(messaging.Serializer):
def __init__(self, base):
self._base = base
def serialize_entity(self, context, entity):
if not self._base:
return entity
return self._base.serialize_entity(context, entity)
def deserialize_entity(self, context, entity):
if not self._base:
return entity
return self._base.deserialize_entity(context, entity)
def serialize_context(self, context):
return context.to_dict()
class RequestContextSerializer(messaging.RequestContextSerializer):
def deserialize_context(self, context):
return ironic_context.RequestContext.from_dict(context)