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

Fixed orphaned channel setup

This commit is contained in:
Nick Goupinets 2021-02-12 14:06:44 -05:00
parent b247e8cde7
commit c5342c116f
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -66,9 +66,10 @@ public class MdmQueueConsumerLoader {
@SuppressWarnings("unused") @SuppressWarnings("unused")
@PreDestroy @PreDestroy
public void stop() { public void stop() throws Exception {
if (myMdmChannel != null) { if (myMdmChannel != null) {
myMdmChannel.unsubscribe(myMdmMessageHandler); // JMS channel needs to be destroyed to avoid dangling receivers
myMdmChannel.destroy();
ourLog.info("MDM Matching Consumer unsubscribed from Matching Channel {} with name {}", myMdmChannel.getClass().getName(), myMdmChannel.getName()); ourLog.info("MDM Matching Consumer unsubscribed from Matching Channel {} with name {}", myMdmChannel.getClass().getName(), myMdmChannel.getName());
} }
} }