diff --git a/hapi-fhir-jpaserver-mdm/src/main/java/ca/uhn/fhir/jpa/mdm/broker/MdmQueueConsumerLoader.java b/hapi-fhir-jpaserver-mdm/src/main/java/ca/uhn/fhir/jpa/mdm/broker/MdmQueueConsumerLoader.java index 4616e88752c..3c19cf8b973 100644 --- a/hapi-fhir-jpaserver-mdm/src/main/java/ca/uhn/fhir/jpa/mdm/broker/MdmQueueConsumerLoader.java +++ b/hapi-fhir-jpaserver-mdm/src/main/java/ca/uhn/fhir/jpa/mdm/broker/MdmQueueConsumerLoader.java @@ -51,7 +51,9 @@ public class MdmQueueConsumerLoader { public void startListeningToMdmChannel() { if (myMdmChannel == null) { ChannelConsumerSettings config = new ChannelConsumerSettings(); + config.setConcurrentConsumers(myMdmSettings.getConcurrentConsumers()); + myMdmChannel = myChannelFactory.getOrCreateReceiver(IMdmSettings.EMPI_CHANNEL_NAME, ResourceModifiedJsonMessage.class, config); if (myMdmChannel == null) { ourLog.error("Unable to create receiver for {}", IMdmSettings.EMPI_CHANNEL_NAME); diff --git a/hapi-fhir-server-mdm/src/main/java/ca/uhn/fhir/mdm/api/IMdmSettings.java b/hapi-fhir-server-mdm/src/main/java/ca/uhn/fhir/mdm/api/IMdmSettings.java index c0e0100ae2f..83bf4343d89 100644 --- a/hapi-fhir-server-mdm/src/main/java/ca/uhn/fhir/mdm/api/IMdmSettings.java +++ b/hapi-fhir-server-mdm/src/main/java/ca/uhn/fhir/mdm/api/IMdmSettings.java @@ -26,7 +26,6 @@ import java.util.stream.Collectors; public interface IMdmSettings { - String MDM_CHANNEL_NAME = "mdm"; String EMPI_CHANNEL_NAME = "empi"; // Parallel processing of MDM can result in missed matches. Best to single-thread. diff --git a/hapi-fhir-server-mdm/src/main/java/ca/uhn/fhir/mdm/rules/config/MdmSettings.java b/hapi-fhir-server-mdm/src/main/java/ca/uhn/fhir/mdm/rules/config/MdmSettings.java index 5fe71b9abd6..80e092fe4ff 100644 --- a/hapi-fhir-server-mdm/src/main/java/ca/uhn/fhir/mdm/rules/config/MdmSettings.java +++ b/hapi-fhir-server-mdm/src/main/java/ca/uhn/fhir/mdm/rules/config/MdmSettings.java @@ -68,11 +68,6 @@ public class MdmSettings implements IMdmSettings { return myConcurrentConsumers; } - public MdmSettings setConcurrentConsumers(int theConcurrentConsumers) { - myConcurrentConsumers = theConcurrentConsumers; - return this; - } - public String getScriptText() { return myScriptText; }