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]¶