'Push receiver, will always receive resources of the same type.'

@oslo_messaging.expected_exceptions(rpc_exc.CallbackNotFound)
def push(self, context, **kwargs):

    resource_list = kwargs['resource_list']
    event_type = kwargs['event_type']
    resource_objs = [obj_base.NeutronObject.clean_obj_from_primitive(resource) for resource in resource_list]
    resource_type = resources.get_resource_type(resource_objs[0])
    cons_registry.push(context, resource_type, resource_objs, event_type)
