

def message_received(self, msg, headers):
    gc = self._routing_obj.container.governance_controller
    if gc:
        gc.check_process_operation_preconditions(self._routing_obj, msg, headers)
    (result, response_headers) = RPCResponseEndpointUnit.message_received(self, msg, headers)
    try:
        response_headers['process-saturation'] = self._get_process_saturation()
    except Exception as ex:
        log.warn('Could not set process-saturation header, ignoring: %s', ex)
    return (result, response_headers)

dataset/ETHPy150Open ooici/pyon/pyon/ion/endpoint.py ProcessRPCResponseEndpointUnit.message_received/original