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

Remove mutator

This commit is contained in:
Tadgh 2021-01-25 09:55:31 -05:00
parent aa37884b2e
commit c572575412
3 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -42,6 +42,8 @@ public class MdmQueueConsumerLoader {
private MdmMessageHandler myMdmMessageHandler;
@Autowired
private IChannelFactory myChannelFactory;
@Autowired
private IMdmSettings myMdmSettings;
protected IChannelReceiver myMdmChannel;
@ -49,9 +51,8 @@ public class MdmQueueConsumerLoader {
public void startListeningToMdmChannel() {
if (myMdmChannel == null) {
ChannelConsumerSettings config = new ChannelConsumerSettings();
//All MDM must be done single-threaded
config.setConcurrentConsumers(1);
config.setConcurrentConsumers(myMdmSettings.getConcurrentConsumers());
myMdmChannel = myChannelFactory.getOrCreateReceiver(IMdmSettings.EMPI_CHANNEL_NAME, ResourceModifiedJsonMessage.class, config);
if (myMdmChannel == null) {

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 {
String MDM_CHANNEL_NAME = "mdm";
String EMPI_CHANNEL_NAME = "empi";
// 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

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