add executor injection to dstu3 measureservice

This commit is contained in:
justin.mckelvy 2023-05-16 12:45:03 -06:00
parent f84033de0c
commit d65a7a6697

View File

@ -54,6 +54,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import java.util.Collections; import java.util.Collections;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ExecutorService;
import static ca.uhn.fhir.cr.constant.MeasureReportConstants.COUNTRY_CODING_SYSTEM_CODE; import static ca.uhn.fhir.cr.constant.MeasureReportConstants.COUNTRY_CODING_SYSTEM_CODE;
import static ca.uhn.fhir.cr.constant.MeasureReportConstants.MEASUREREPORT_MEASURE_SUPPLEMENTALDATA_EXTENSION; import static ca.uhn.fhir.cr.constant.MeasureReportConstants.MEASUREREPORT_MEASURE_SUPPLEMENTALDATA_EXTENSION;
@ -130,6 +131,9 @@ public class MeasureService implements IDaoRegistryUser {
@Autowired @Autowired
protected DaoRegistry myDaoRegistry; protected DaoRegistry myDaoRegistry;
@Autowired
private ExecutorService myMeasureExecutor;
protected RequestDetails myRequestDetails; protected RequestDetails myRequestDetails;
/** /**
* Get The details (such as tenant) of this request. Usually auto-populated HAPI. * Get The details (such as tenant) of this request. Usually auto-populated HAPI.
@ -182,6 +186,8 @@ public class MeasureService implements IDaoRegistryUser {
TerminologyProvider terminologyProvider; TerminologyProvider terminologyProvider;
myMeasureEvaluationOptions.setMeasureExecutor(myMeasureExecutor);
if (theTerminologyEndpoint != null) { if (theTerminologyEndpoint != null) {
IGenericClient client = Clients.forEndpoint(getFhirContext(), theTerminologyEndpoint); IGenericClient client = Clients.forEndpoint(getFhirContext(), theTerminologyEndpoint);
terminologyProvider = new Dstu3FhirTerminologyProvider(client); terminologyProvider = new Dstu3FhirTerminologyProvider(client);