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

fixed asymmetry between add and remove

This commit is contained in:
Ken Stevens 2019-10-01 11:22:09 -04:00
parent ca95791d2e
commit 718b2c793d
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hapi-fhir-jpaserver-subscription/src/main/java/ca/uhn/fhir/jpa/subscription/module/channel/SubscriptionChannelRegistry.java
View File

@ -56,7 +56,11 @@ public class SubscriptionChannelRegistry {
} }
public void remove(ActiveSubscription theActiveSubscription) { public void remove(ActiveSubscription theActiveSubscription) {
if (!myModelConfig.isSubscriptionMatchingEnabled()) {
return;
}
String channelName = theActiveSubscription.getChannelName(); String channelName = theActiveSubscription.getChannelName();
ourLog.info("Removing subscription {} from channel {}", theActiveSubscription.getId() ,channelName);
boolean removed = myActiveSubscriptionByChannelName.remove(channelName, theActiveSubscription.getId()); boolean removed = myActiveSubscriptionByChannelName.remove(channelName, theActiveSubscription.getId());
if (!removed) { if (!removed) {
ourLog.warn("Failed to remove subscription {} from channel {}", theActiveSubscription.getId() ,channelName); ourLog.warn("Failed to remove subscription {} from channel {}", theActiveSubscription.getId() ,channelName);
@ -82,7 +86,7 @@ public class SubscriptionChannelRegistry {
@VisibleForTesting @VisibleForTesting
public void logForUnitTest() { public void logForUnitTest() {
ourLog.info("Channels: {}", size()); ourLog.info("{} Channels: {}", this, size());
for (String key : myActiveSubscriptionByChannelName.keySet()) { for (String key : myActiveSubscriptionByChannelName.keySet()) {
Collection<String> list = myActiveSubscriptionByChannelName.get(key); Collection<String> list = myActiveSubscriptionByChannelName.get(key);
for (String value : list) { for (String value : list) {