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

fixed

This commit is contained in:
Ken Stevens 2019-02-02 19:07:06 -05:00
parent 37670ac039
commit 84db66d2e3
1 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
hapi-fhir-jpaserver-subscription/src/main/java/ca/uhn/fhir/jpa/subscription/module/standalone/StandaloneSubscriptionMessageHandler.java
View File

@ -62,25 +62,23 @@ public class StandaloneSubscriptionMessageHandler implements MessageHandler {
} }
public void updateSubscriptionRegistryAndPerformMatching(ResourceModifiedMessage theResourceModifiedMessage) { public void updateSubscriptionRegistryAndPerformMatching(ResourceModifiedMessage theResourceModifiedMessage) {
if (isSubscription(theResourceModifiedMessage)) {
handleSubscriptionActivation(theResourceModifiedMessage);
}
mySubscriptionMatchingSubscriber.matchActiveSubscriptionsAndDeliver(theResourceModifiedMessage);
}
private void handleSubscriptionActivation(ResourceModifiedMessage theResourceModifiedMessage) {
switch (theResourceModifiedMessage.getOperationType()) { switch (theResourceModifiedMessage.getOperationType()) {
case DELETE: case DELETE:
mySubscriptionRegistry.unregisterSubscription(theResourceModifiedMessage.getId(myFhirContext)); if (isSubscription(theResourceModifiedMessage)) {
break; mySubscriptionRegistry.unregisterSubscription(theResourceModifiedMessage.getId(myFhirContext));
}
return;
case CREATE: case CREATE:
case UPDATE: case UPDATE:
registerActiveSubscription(theResourceModifiedMessage.getNewPayload(myFhirContext)); if (isSubscription(theResourceModifiedMessage)) {
registerActiveSubscription(theResourceModifiedMessage.getNewPayload(myFhirContext));
}
break; break;
default: default:
break; break;
} }
mySubscriptionMatchingSubscriber.matchActiveSubscriptionsAndDeliver(theResourceModifiedMessage);
} }
private boolean isSubscription(ResourceModifiedMessage theResourceModifiedMessage) { private boolean isSubscription(ResourceModifiedMessage theResourceModifiedMessage) {