honeymoose
/
hapi-fhir
mirror of https://github.com/hapifhir/hapi-fhir.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2324 from hapifhir/single-threading-mdm 

Ensure Single threading mdm
This commit is contained in:
Tadgh 2021-01-29 10:01:56 -05:00 committed by GitHub
parent 947622d25f c572575412
commit 96b4e5ab38
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hapi-fhir-jpaserver-mdm/src/main/java/ca/uhn/fhir/jpa/mdm/broker/MdmQueueConsumerLoader.java
View File

@ -51,7 +51,9 @@ public class MdmQueueConsumerLoader {
public void startListeningToMdmChannel() { public void startListeningToMdmChannel() {
if (myMdmChannel == null) { if (myMdmChannel == null) {
ChannelConsumerSettings config = new ChannelConsumerSettings(); ChannelConsumerSettings config = new ChannelConsumerSettings();
config.setConcurrentConsumers(myMdmSettings.getConcurrentConsumers()); config.setConcurrentConsumers(myMdmSettings.getConcurrentConsumers());
myMdmChannel = myChannelFactory.getOrCreateReceiver(IMdmSettings.EMPI_CHANNEL_NAME, ResourceModifiedJsonMessage.class, config); myMdmChannel = myChannelFactory.getOrCreateReceiver(IMdmSettings.EMPI_CHANNEL_NAME, ResourceModifiedJsonMessage.class, config);
if (myMdmChannel == null) { if (myMdmChannel == null) {
ourLog.error("Unable to create receiver for {}", IMdmSettings.EMPI_CHANNEL_NAME); ourLog.error("Unable to create receiver for {}", IMdmSettings.EMPI_CHANNEL_NAME);

1
hapi-fhir-server-mdm/src/main/java/ca/uhn/fhir/mdm/api/IMdmSettings.java
View File

@ -26,7 +26,6 @@ import java.util.stream.Collectors;
public interface IMdmSettings { public interface IMdmSettings {
String MDM_CHANNEL_NAME = "mdm";
String EMPI_CHANNEL_NAME = "empi"; String EMPI_CHANNEL_NAME = "empi";
// Parallel processing of MDM can result in missed matches. Best to single-thread. // Parallel processing of MDM can result in missed matches. Best to single-thread.

5
hapi-fhir-server-mdm/src/main/java/ca/uhn/fhir/mdm/rules/config/MdmSettings.java
View File

@ -68,11 +68,6 @@ public class MdmSettings implements IMdmSettings {
return myConcurrentConsumers; return myConcurrentConsumers;
} }
public MdmSettings setConcurrentConsumers(int theConcurrentConsumers) {
myConcurrentConsumers = theConcurrentConsumers;
return this;
}
public String getScriptText() { public String getScriptText() {
return myScriptText; return myScriptText;
} }