Class RootNamespaceAutoConfiguration

java.lang.Object

io.temporal.spring.boot.autoconfigure.RootNamespaceAutoConfiguration

@AutoConfiguration(after={ServiceStubsAutoConfiguration.class,OpenTracingAutoConfiguration.class})
@EnableConfigurationProperties(TemporalProperties.class)
@ConditionalOnBean(ServiceStubsAutoConfiguration.class)
@ConditionalOnExpression("${spring.temporal.test-server.enabled:false} || '${spring.temporal.connection.target:}'.length() > 0")
public class RootNamespaceAutoConfiguration
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RootNamespaceAutoConfiguration.WorkerFactoryStarter

Constructor Summary

Constructors

Constructor	Description
RootNamespaceAutoConfiguration(org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory)

Method Summary

Modifier and Type	Method	Description
io.temporal.client.WorkflowClient	client(ClientTemplate clientTemplate)
ClientTemplate	clientTemplate(NamespaceTemplate rootNamespaceTemplate)	Client
NamespaceTemplate	rootNamespaceTemplate(TemporalProperties properties, io.temporal.serviceclient.WorkflowServiceStubs workflowServiceStubs, Map<String,io.temporal.common.converter.DataConverter> dataConverters, io.temporal.common.converter.DataConverter mainDataConverter, io.opentracing.Tracer otTracer, List<io.temporal.common.interceptors.WorkflowClientInterceptor> workflowClientInterceptors, List<io.temporal.common.interceptors.ScheduleClientInterceptor> scheduleClientInterceptors, List<io.temporal.common.interceptors.WorkerInterceptor> workerInterceptors, TestWorkflowEnvironmentAdapter testWorkflowEnvironment, Map<String,TemporalOptionsCustomizer<io.temporal.worker.WorkerFactoryOptions.Builder>> workerFactoryCustomizerMap, Map<String,TemporalOptionsCustomizer<io.temporal.worker.WorkerOptions.Builder>> workerCustomizerMap, Map<String,TemporalOptionsCustomizer<io.temporal.client.WorkflowClientOptions.Builder>> clientCustomizerMap, Map<String,TemporalOptionsCustomizer<io.temporal.client.schedules.ScheduleClientOptions.Builder>> scheduleCustomizerMap, Map<String,TemporalOptionsCustomizer<io.temporal.worker.WorkflowImplementationOptions.Builder>> workflowImplementationCustomizerMap, List<io.temporal.client.WorkflowClientPlugin> workflowClientPlugins, List<io.temporal.client.schedules.ScheduleClientPlugin> scheduleClientPlugins, List<io.temporal.worker.WorkerPlugin> workerPlugins)
io.temporal.client.schedules.ScheduleClient	scheduleClient(ClientTemplate clientTemplate)
io.temporal.worker.WorkerFactory	workerFactory(WorkersTemplate workersTemplate)
RootNamespaceAutoConfiguration.WorkerFactoryStarter	workerFactoryStarter(io.temporal.worker.WorkerFactory workerFactory)
Collection<io.temporal.worker.Worker>	workers(WorkersTemplate workersTemplate)
WorkersTemplate	workersTemplate(NamespaceTemplate temporalRootNamespaceTemplate)	Workers

Methods inherited from class java.lang.Object

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

Constructor Details

RootNamespaceAutoConfiguration

public RootNamespaceAutoConfiguration(org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory)

Method Details

rootNamespaceTemplate

@Bean(name="temporalRootNamespaceTemplate")
public NamespaceTemplate rootNamespaceTemplate(TemporalProperties properties,
 io.temporal.serviceclient.WorkflowServiceStubs workflowServiceStubs,
 @Autowired(required=false) @Nullable
 Map<String,io.temporal.common.converter.DataConverter> dataConverters,
 @Qualifier("mainDataConverter") @Autowired(required=false) @Nullable
 io.temporal.common.converter.DataConverter mainDataConverter,
 @Autowired(required=false) @Nullable
 io.opentracing.Tracer otTracer,
 @Autowired(required=false) @Nullable
 List<io.temporal.common.interceptors.WorkflowClientInterceptor> workflowClientInterceptors,
 @Autowired(required=false) @Nullable
 List<io.temporal.common.interceptors.ScheduleClientInterceptor> scheduleClientInterceptors,
 @Autowired(required=false) @Nullable
 List<io.temporal.common.interceptors.WorkerInterceptor> workerInterceptors,
 @Qualifier("temporalTestWorkflowEnvironmentAdapter") @Autowired(required=false) @Nullable
 TestWorkflowEnvironmentAdapter testWorkflowEnvironment,
 @Autowired(required=false) @Nullable
 Map<String,TemporalOptionsCustomizer<io.temporal.worker.WorkerFactoryOptions.Builder>> workerFactoryCustomizerMap,
 @Autowired(required=false) @Nullable
 Map<String,TemporalOptionsCustomizer<io.temporal.worker.WorkerOptions.Builder>> workerCustomizerMap,
 @Autowired(required=false) @Nullable
 Map<String,TemporalOptionsCustomizer<io.temporal.client.WorkflowClientOptions.Builder>> clientCustomizerMap,
 @Autowired(required=false) @Nullable
 Map<String,TemporalOptionsCustomizer<io.temporal.client.schedules.ScheduleClientOptions.Builder>> scheduleCustomizerMap,
 @Autowired(required=false) @Nullable
 Map<String,TemporalOptionsCustomizer<io.temporal.worker.WorkflowImplementationOptions.Builder>> workflowImplementationCustomizerMap,
 @Autowired(required=false) @Nullable
 List<io.temporal.client.WorkflowClientPlugin> workflowClientPlugins,
 @Autowired(required=false) @Nullable
 List<io.temporal.client.schedules.ScheduleClientPlugin> scheduleClientPlugins,
 @Autowired(required=false) @Nullable
 List<io.temporal.worker.WorkerPlugin> workerPlugins)

clientTemplate

@Primary
@Bean(name="temporalClientTemplate")
public ClientTemplate clientTemplate(@Qualifier("temporalRootNamespaceTemplate")
 NamespaceTemplate rootNamespaceTemplate)

Client

client

@Primary
@Bean(name="temporalWorkflowClient")
public io.temporal.client.WorkflowClient client(ClientTemplate clientTemplate)

scheduleClient

@Primary
@Bean(name="temporalScheduleClient")
public io.temporal.client.schedules.ScheduleClient scheduleClient(ClientTemplate clientTemplate)

workersTemplate

@Primary
@Bean(name="temporalWorkersTemplate")
@Conditional(io.temporal.spring.boot.autoconfigure.WorkersPresentCondition.class)
@DependsOn("temporalClientTemplate")
public WorkersTemplate workersTemplate(@Qualifier("temporalRootNamespaceTemplate")
 NamespaceTemplate temporalRootNamespaceTemplate)

Workers

workerFactory

@Primary
@Bean(name="temporalWorkerFactory",
      destroyMethod="shutdown")
@Conditional(io.temporal.spring.boot.autoconfigure.WorkersPresentCondition.class)
public io.temporal.worker.WorkerFactory workerFactory(@Qualifier("temporalWorkersTemplate")
 WorkersTemplate workersTemplate)

workers

@Primary
@Bean(name="temporalWorkers")
@Conditional(io.temporal.spring.boot.autoconfigure.WorkersPresentCondition.class)
public Collection<io.temporal.worker.Worker> workers(@Qualifier("temporalWorkersTemplate")
 WorkersTemplate workersTemplate)

workerFactoryStarter

@Primary
@ConditionalOnProperty(prefix="spring.temporal",
                       name="start-workers",
                       matchIfMissing=true)
@Conditional(io.temporal.spring.boot.autoconfigure.WorkersPresentCondition.class)
@Bean
public RootNamespaceAutoConfiguration.WorkerFactoryStarter workerFactoryStarter(io.temporal.worker.WorkerFactory workerFactory)