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

Add a bit of logging to subscription triggering

This commit is contained in:
James Agnew 2018-10-17 08:32:57 -04:00
parent b220154e9c
commit 4b5dcce021
2 changed files with 3 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/provider/SubscriptionTriggeringProvider.java
View File

@ -173,6 +173,7 @@ public class SubscriptionTriggeringProvider implements IResourceProvider, Applic
synchronized (myActiveJobs) { synchronized (myActiveJobs) {
myActiveJobs.add(jobDetails); myActiveJobs.add(jobDetails);
} }
ourLog.info("Subscription triggering requested for {} resource and {} search - Gave job ID: {}", resourceIds.size(), searchUrls.size(), jobDetails.getJobId());
// Create a parameters response // Create a parameters response
IBaseParameters retVal = ParametersUtil.newInstance(myFhirContext); IBaseParameters retVal = ParametersUtil.newInstance(myFhirContext);

12
hapi-fhir-jpaserver-base/src/test/java/ca/uhn/fhir/jpa/subscription/SubscriptionTriggeringDstu3Test.java
View File

@ -62,8 +62,8 @@ public class SubscriptionTriggeringDstu3Test extends BaseResourceProviderDstu3Te
myDaoConfig.setAllowMultipleDelete(true); myDaoConfig.setAllowMultipleDelete(true);
ourLog.info("Deleting all subscriptions"); ourLog.info("Deleting all subscriptions");
ourClient.delete().resourceConditionalByUrl("Subscription?status=active").execute(); ourClient.delete().resourceConditionalByUrl("Subscription?_lastUpdated=lt3000").execute();
ourClient.delete().resourceConditionalByUrl("Observation?code:missing=false").execute(); ourClient.delete().resourceConditionalByUrl("Observation?_lastUpdated=lt3000").execute();
ourLog.info("Done deleting all subscriptions"); ourLog.info("Done deleting all subscriptions");
myDaoConfig.setAllowMultipleDelete(new DaoConfig().isAllowMultipleDelete()); myDaoConfig.setAllowMultipleDelete(new DaoConfig().isAllowMultipleDelete());
@ -151,8 +151,6 @@ public class SubscriptionTriggeringDstu3Test extends BaseResourceProviderDstu3Te
waitForSize(1, ourUpdatedObservations); waitForSize(1, ourUpdatedObservations);
assertEquals(Constants.CT_FHIR_JSON_NEW, ourContentTypes.get(0)); assertEquals(Constants.CT_FHIR_JSON_NEW, ourContentTypes.get(0));
ourClient.registerInterceptor(new LoggingInterceptor(true));
Parameters response = ourClient Parameters response = ourClient
.operation() .operation()
.onInstance(subscriptionId) .onInstance(subscriptionId)
@ -199,8 +197,6 @@ public class SubscriptionTriggeringDstu3Test extends BaseResourceProviderDstu3Te
ourSubscriptionTriggeringProvider.setMaxSubmitPerPass(33); ourSubscriptionTriggeringProvider.setMaxSubmitPerPass(33);
ourClient.registerInterceptor(new LoggingInterceptor(true));
Parameters response = ourClient Parameters response = ourClient
.operation() .operation()
.onInstance(sub1id) .onInstance(sub1id)
@ -257,8 +253,6 @@ public class SubscriptionTriggeringDstu3Test extends BaseResourceProviderDstu3Te
ourSubscriptionTriggeringProvider.setMaxSubmitPerPass(33); ourSubscriptionTriggeringProvider.setMaxSubmitPerPass(33);
ourClient.registerInterceptor(new LoggingInterceptor(true));
Parameters response = ourClient Parameters response = ourClient
.operation() .operation()
.onInstance(sub1id) .onInstance(sub1id)
@ -322,8 +316,6 @@ public class SubscriptionTriggeringDstu3Test extends BaseResourceProviderDstu3Te
ourSubscriptionTriggeringProvider.setMaxSubmitPerPass(50); ourSubscriptionTriggeringProvider.setMaxSubmitPerPass(50);
ourClient.registerInterceptor(new LoggingInterceptor(true));
Parameters response = ourClient Parameters response = ourClient
.operation() .operation()
.onType(Subscription.class) .onType(Subscription.class)