Package ca.uhn.fhir.batch2.config

Class BaseBatch2Config

java.lang.Object

ca.uhn.fhir.batch2.config.BaseBatch2Config

@Configuration
public abstract class BaseBatch2Config
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CHANNEL_NAME

Constructor Summary

Constructors

Constructor	Description
BaseBatch2Config()

Method Summary

Modifier and Type	Method	Description
IJobCoordinator	batch2JobCoordinator(JobDefinitionRegistry theJobDefinitionRegistry, BatchJobSender theBatchJobSender, WorkChunkProcessor theExecutor, IJobMaintenanceService theJobMaintenanceService, IHapiTransactionService theTransactionService)
JobDefinitionRegistry	batch2JobDefinitionRegistry()
IJobMaintenanceService	batch2JobMaintenanceService(ISchedulerService theSchedulerService, JobDefinitionRegistry theJobDefinitionRegistry, JpaStorageSettings theStorageSettings, BatchJobSender theBatchJobSender, WorkChunkProcessor theExecutor, IReductionStepExecutorService theReductionStepExecutorService)
Batch2JobRegisterer	batch2JobRegisterer()
IChannelProducer	batch2ProcessingChannelProducer(IChannelFactory theChannelFactory)
IChannelReceiver	batch2ProcessingChannelReceiver(IChannelFactory theChannelFactory)
BatchJobSender	batchJobSender()
protected int	getConcurrentConsumers()	Can be overridden
IJobPartitionProvider	jobPartitionProvider(ca.uhn.fhir.context.FhirContext theFhirContext, IRequestPartitionHelperSvc theRequestPartitionHelperSvc, ca.uhn.fhir.jpa.searchparam.MatchUrlService theMatchUrlService)
WorkChunkProcessor	jobStepExecutorService(BatchJobSender theBatchJobSender)
IReductionStepExecutorService	reductionStepExecutorService(IJobPersistence theJobPersistence, IHapiTransactionService theTransactionService, JobDefinitionRegistry theJobDefinitionRegistry)

Methods inherited from class java.lang.Object

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

Field Details

CHANNEL_NAME

public static final String CHANNEL_NAME

See Also:

• Constant Field Values

Constructor Details

BaseBatch2Config

public BaseBatch2Config()

Method Details

batch2JobDefinitionRegistry

@Bean
public JobDefinitionRegistry batch2JobDefinitionRegistry()

jobStepExecutorService

@Bean
public WorkChunkProcessor jobStepExecutorService(BatchJobSender theBatchJobSender)

batchJobSender

@Bean
public BatchJobSender batchJobSender()

batch2JobCoordinator

@Bean
public IJobCoordinator batch2JobCoordinator(JobDefinitionRegistry theJobDefinitionRegistry,
 BatchJobSender theBatchJobSender,
 WorkChunkProcessor theExecutor,
 IJobMaintenanceService theJobMaintenanceService,
 IHapiTransactionService theTransactionService)

reductionStepExecutorService

@Bean
public IReductionStepExecutorService reductionStepExecutorService(IJobPersistence theJobPersistence,
 IHapiTransactionService theTransactionService,
 JobDefinitionRegistry theJobDefinitionRegistry)

batch2JobMaintenanceService

@Bean
public IJobMaintenanceService batch2JobMaintenanceService(ISchedulerService theSchedulerService,
 JobDefinitionRegistry theJobDefinitionRegistry,
 JpaStorageSettings theStorageSettings,
 BatchJobSender theBatchJobSender,
 WorkChunkProcessor theExecutor,
 IReductionStepExecutorService theReductionStepExecutorService)

batch2ProcessingChannelProducer

@Bean
public IChannelProducer batch2ProcessingChannelProducer(IChannelFactory theChannelFactory)

batch2ProcessingChannelReceiver

@Bean
public IChannelReceiver batch2ProcessingChannelReceiver(IChannelFactory theChannelFactory)

batch2JobRegisterer

@Bean
public Batch2JobRegisterer batch2JobRegisterer()

getConcurrentConsumers

protected int getConcurrentConsumers()

Can be overridden

jobPartitionProvider

@Bean
public IJobPartitionProvider jobPartitionProvider(ca.uhn.fhir.context.FhirContext theFhirContext,
 IRequestPartitionHelperSvc theRequestPartitionHelperSvc,
 ca.uhn.fhir.jpa.searchparam.MatchUrlService theMatchUrlService)