heat.common.messaging module

heat.common.messaging module

class heat.common.messaging.JsonPayloadSerializer[source]

Bases: oslo_messaging.serializer.NoOpSerializer

classmethod serialize_entity(context, entity)[source]

Serialize something to primitive form.

Parameters:
  • ctxt – Request context, in deserialized form
  • entity – Entity to be serialized
Returns:

Serialized form of entity

class heat.common.messaging.RequestContextSerializer(base)[source]

Bases: oslo_messaging.serializer.Serializer

static deserialize_context(ctxt)[source]
deserialize_entity(ctxt, entity)[source]

Deserialize something from primitive form.

Parameters:
  • ctxt – Request context, in deserialized form
  • entity – Primitive to be deserialized
Returns:

Deserialized form of entity

static serialize_context(ctxt)[source]
serialize_entity(ctxt, entity)[source]

Serialize something to primitive form.

Parameters:
  • ctxt – Request context, in deserialized form
  • entity – Entity to be serialized
Returns:

Serialized form of entity

heat.common.messaging.cleanup()[source]

Cleanup the oslo_messaging layer.

heat.common.messaging.get_notifier(publisher_id)[source]

Return a configured oslo_messaging notifier.

heat.common.messaging.get_rpc_client(**kwargs)[source]

Return a configured oslo_messaging RPCClient.

heat.common.messaging.get_rpc_server(target, endpoint)[source]

Return a configured oslo_messaging rpc server.

heat.common.messaging.get_specific_transport(url, optional, exmods, is_for_notifications=False)[source]
heat.common.messaging.setup(url=None, optional=False)[source]

Initialise the oslo_messaging layer.

heat.common.messaging.setup_transports(url, optional)[source]
Creative Commons Attribution 3.0 License

Except where otherwise noted, this document is licensed under Creative Commons Attribution 3.0 License. See all OpenStack Legal Documents.