Package ca.uhn.fhir.batch2.coordinator

Class JobCoordinatorImpl

java.lang.Object

ca.uhn.fhir.batch2.coordinator.JobCoordinatorImpl

All Implemented Interfaces:

IJobCoordinator

public class JobCoordinatorImpl
extends Object
implements IJobCoordinator

Constructor Summary

Constructors

Constructor	Description
JobCoordinatorImpl(BatchJobSender theBatchJobSender, IChannelReceiver theWorkChannelReceiver, IJobPersistence theJobPersistence, JobDefinitionRegistry theJobDefinitionRegistry, WorkChunkProcessor theExecutorSvc, IJobMaintenanceService theJobMaintenanceService, IHapiTransactionService theTransactionService)	Constructor

Method Summary

Modifier and Type	Method	Description
JobOperationResultJson	cancelInstance(String theInstanceId)
org.springframework.data.domain.Page<JobInstance>	fetchAllJobInstances(JobInstanceFetchRequest theFetchRequest)	Fetches all job instances tht meet the FetchRequest criteria
JobInstance	getInstance(String theInstanceId)	Fetch details about a job instance
List<JobInstance>	getInstances(int thePageSize, int thePageIndex)	Fetch all job instances
List<JobInstance>	getInstancesbyJobDefinitionIdAndEndedStatus(String theJobDefinitionId, Boolean theEnded, int theCount, int theStart)
List<JobInstance>	getJobInstancesByJobDefinitionId(String theJobDefinitionId, int theCount, int theStart)	Fetches all jobs by job definition id
List<JobInstance>	getJobInstancesByJobDefinitionIdAndStatuses(String theJobDefinitionId, Set<StatusEnum> theStatuses, int theCount, int theStart)	Fetches all job instances by job definition id and statuses
List<JobInstance>	getRecentInstances(int theCount, int theStart)	Fetch recent job instances
void	start()
Batch2JobStartResponse	startInstance(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, JobInstanceStartRequest theStartRequest)	Starts a new job instance
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface ca.uhn.fhir.batch2.api.IJobCoordinator

startInstance

Constructor Details

JobCoordinatorImpl

public JobCoordinatorImpl(@Nonnull
 BatchJobSender theBatchJobSender,
 @Nonnull
 IChannelReceiver theWorkChannelReceiver,
 @Nonnull
 IJobPersistence theJobPersistence,
 @Nonnull
 JobDefinitionRegistry theJobDefinitionRegistry,
 @Nonnull
 WorkChunkProcessor theExecutorSvc,
 @Nonnull
 IJobMaintenanceService theJobMaintenanceService,
 @Nonnull
 IHapiTransactionService theTransactionService)

Constructor

Method Details

startInstance

public Batch2JobStartResponse startInstance(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 JobInstanceStartRequest theStartRequest)

Description copied from interface: IJobCoordinator

Starts a new job instance

Specified by:

startInstance in interface IJobCoordinator

Parameters:

theRequestDetails - The request details associated with the request. This will get used to validate that the request is appropriate for the given user, so if at all possible it should be the original RequestDetails from the server request.

theStartRequest - The request, containing the job type and parameters

Returns:

Returns a unique ID for this job execution

getInstance

@Nonnull
public JobInstance getInstance(String theInstanceId)

Description copied from interface: IJobCoordinator

Fetch details about a job instance

Specified by:

getInstance in interface IJobCoordinator

Parameters:

theInstanceId - The instance ID

Returns:

Returns the current instance details

getInstances

public List<JobInstance> getInstances(int thePageSize,
 int thePageIndex)

Description copied from interface: IJobCoordinator

Fetch all job instances

Specified by:

getInstances in interface IJobCoordinator

getRecentInstances

public List<JobInstance> getRecentInstances(int theCount,
 int theStart)

Description copied from interface: IJobCoordinator

Fetch recent job instances

Specified by:

getRecentInstances in interface IJobCoordinator

getInstancesbyJobDefinitionIdAndEndedStatus

public List<JobInstance> getInstancesbyJobDefinitionIdAndEndedStatus(String theJobDefinitionId,
 @Nullable
 Boolean theEnded,
 int theCount,
 int theStart)

Specified by:

getInstancesbyJobDefinitionIdAndEndedStatus in interface IJobCoordinator

getJobInstancesByJobDefinitionIdAndStatuses

public List<JobInstance> getJobInstancesByJobDefinitionIdAndStatuses(String theJobDefinitionId,
 Set<StatusEnum> theStatuses,
 int theCount,
 int theStart)

Description copied from interface: IJobCoordinator

Fetches all job instances by job definition id and statuses

Specified by:

getJobInstancesByJobDefinitionIdAndStatuses in interface IJobCoordinator

getJobInstancesByJobDefinitionId

public List<JobInstance> getJobInstancesByJobDefinitionId(String theJobDefinitionId,
 int theCount,
 int theStart)

Description copied from interface: IJobCoordinator

Fetches all jobs by job definition id

Specified by:

getJobInstancesByJobDefinitionId in interface IJobCoordinator

fetchAllJobInstances

public org.springframework.data.domain.Page<JobInstance> fetchAllJobInstances(JobInstanceFetchRequest theFetchRequest)

Description copied from interface: IJobCoordinator

Fetches all job instances tht meet the FetchRequest criteria

Specified by:

fetchAllJobInstances in interface IJobCoordinator

Parameters:

theFetchRequest - - fetch request

Returns:

- page of job instances

cancelInstance

public JobOperationResultJson cancelInstance(String theInstanceId)
                                      throws ca.uhn.fhir.rest.server.exceptions.ResourceNotFoundException

Specified by:

cancelInstance in interface IJobCoordinator

Throws:

ca.uhn.fhir.rest.server.exceptions.ResourceNotFoundException

start

@PostConstruct
public void start()

stop

@PreDestroy
public void stop()