heat.common.messaging module¶

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

Bases: Serializer

static deserialize_context(ctxt)[source]¶

Deserialize a dictionary into a request context.

Parameters:

ctxt – Request context dictionary

Returns:

Deserialized form of entity

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 a request context into a dictionary.

Parameters:

ctxt – Request context

Returns:

Serialized form of context

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