Package ca.uhn.fhir.batch2.coordinator

Class JobDefinitionRegistry

java.lang.Object

ca.uhn.fhir.batch2.coordinator.JobDefinitionRegistry

public class JobDefinitionRegistry
extends Object

Constructor Summary

Constructors

Constructor	Description
JobDefinitionRegistry()

Method Summary

Modifier and Type	Method	Description
<PT extends ca.uhn.fhir.model.api.IModelJson> void	addJobDefinition(JobDefinition<PT> theDefinition)
<PT extends ca.uhn.fhir.model.api.IModelJson> boolean	addJobDefinitionIfNotRegistered(JobDefinition<PT> theDefinition)	Add a job definition only if it is not registered
Optional<JobDefinition<?>>	getJobDefinition(String theJobDefinitionId, int theJobDefinitionVersion)
List<String>	getJobDefinitionIds()
<T extends ca.uhn.fhir.model.api.IModelJson> JobDefinition<T>	getJobDefinitionOrThrowException(JobInstance theJobInstance)
JobDefinition<?>	getJobDefinitionOrThrowException(String theJobDefinitionId, int theJobDefinitionVersion)
Collection<Integer>	getJobDefinitionVersions(String theDefinitionId)
Optional<JobDefinition<?>>	getLatestJobDefinition(String theJobDefinitionId)
boolean	isEmpty()
void	removeJobDefinition(String theDefinitionId, int theVersion)
void	setJobDefinition(JobInstance theInstance)

Methods inherited from class java.lang.Object

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

Constructor Details

JobDefinitionRegistry

public JobDefinitionRegistry()

Method Details

addJobDefinitionIfNotRegistered

public <PT extends ca.uhn.fhir.model.api.IModelJson>
boolean addJobDefinitionIfNotRegistered(@Nonnull
 JobDefinition<PT> theDefinition)

Add a job definition only if it is not registered

Type Parameters:

PT - the job parameter type for the definition

Returns:

true if it did not already exist and was registered

addJobDefinition

public <PT extends ca.uhn.fhir.model.api.IModelJson>
void addJobDefinition(@Nonnull
 JobDefinition<PT> theDefinition)

removeJobDefinition

public void removeJobDefinition(@Nonnull
 String theDefinitionId,
 int theVersion)

getLatestJobDefinition

public Optional<JobDefinition<?>> getLatestJobDefinition(@Nonnull
 String theJobDefinitionId)

getJobDefinition

public Optional<JobDefinition<?>> getJobDefinition(@Nonnull
 String theJobDefinitionId,
 int theJobDefinitionVersion)

getJobDefinitionOrThrowException

public JobDefinition<?> getJobDefinitionOrThrowException(String theJobDefinitionId,
 int theJobDefinitionVersion)

Throws:

JobExecutionFailedException - if the job definition can not be found

setJobDefinition

public void setJobDefinition(JobInstance theInstance)

getJobDefinitionIds

public List<String> getJobDefinitionIds()

Returns:

a list of Job Definition Ids in alphabetical order

isEmpty

public boolean isEmpty()

getJobDefinitionOrThrowException

public <T extends ca.uhn.fhir.model.api.IModelJson>
JobDefinition<T> getJobDefinitionOrThrowException(JobInstance theJobInstance)

getJobDefinitionVersions

public Collection<Integer> getJobDefinitionVersions(String theDefinitionId)