Package ca.uhn.fhir.jpa.subscription.triggering

Class SubscriptionTriggeringSvcImpl

java.lang.Object

ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl

All Implemented Interfaces:

ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs, ISubscriptionTriggeringSvc

public class SubscriptionTriggeringSvcImpl
extends Object
implements ISubscriptionTriggeringSvc, ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SubscriptionTriggeringSvcImpl.Job

Constructor Summary

Constructors

Constructor	Description
SubscriptionTriggeringSvcImpl()

Method Summary

Modifier and Type	Method	Description
void	cancelAll()
int	getActiveJobCount()
void	runDeliveryPass()
void	scheduleJobs(ca.uhn.fhir.jpa.model.sched.ISchedulerService theSchedulerService)
void	setMaxSubmitPerPass(Integer theMaxSubmitPerPass)	Sets the maximum number of resources that will be submitted in a single pass
void	start()
org.hl7.fhir.instance.model.api.IBaseParameters	triggerSubscription(List<org.hl7.fhir.instance.model.api.IPrimitiveType<String>> theResourceIds, List<org.hl7.fhir.instance.model.api.IPrimitiveType<String>> theSearchUrls, org.hl7.fhir.instance.model.api.IIdType theSubscriptionId)
org.hl7.fhir.instance.model.api.IBaseParameters	triggerSubscription(List<org.hl7.fhir.instance.model.api.IPrimitiveType<String>> theResourceIds, List<org.hl7.fhir.instance.model.api.IPrimitiveType<String>> theSearchUrls, org.hl7.fhir.instance.model.api.IIdType theSubscriptionId, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SubscriptionTriggeringSvcImpl

public SubscriptionTriggeringSvcImpl()

Method Details

triggerSubscription

public org.hl7.fhir.instance.model.api.IBaseParameters triggerSubscription(@Nullable
 List<org.hl7.fhir.instance.model.api.IPrimitiveType<String>> theResourceIds,
 @Nullable
 List<org.hl7.fhir.instance.model.api.IPrimitiveType<String>> theSearchUrls,
 @Nullable
 org.hl7.fhir.instance.model.api.IIdType theSubscriptionId,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

triggerSubscription in interface ISubscriptionTriggeringSvc

triggerSubscription

public org.hl7.fhir.instance.model.api.IBaseParameters triggerSubscription(@Nullable
 List<org.hl7.fhir.instance.model.api.IPrimitiveType<String>> theResourceIds,
 @Nullable
 List<org.hl7.fhir.instance.model.api.IPrimitiveType<String>> theSearchUrls,
 @Nullable
 org.hl7.fhir.instance.model.api.IIdType theSubscriptionId)

Specified by:

triggerSubscription in interface ISubscriptionTriggeringSvc

runDeliveryPass

public void runDeliveryPass()

Specified by:

runDeliveryPass in interface ISubscriptionTriggeringSvc

cancelAll

public void cancelAll()

setMaxSubmitPerPass

public void setMaxSubmitPerPass(Integer theMaxSubmitPerPass)

Sets the maximum number of resources that will be submitted in a single pass

start

@PostConstruct
public void start()

scheduleJobs

public void scheduleJobs(ca.uhn.fhir.jpa.model.sched.ISchedulerService theSchedulerService)

Specified by:

scheduleJobs in interface ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs

getActiveJobCount

public int getActiveJobCount()