Class WorkersTemplate

java.lang.Object

io.temporal.spring.boot.autoconfigure.template.WorkersTemplate

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.context.EnvironmentAware

public class WorkersTemplate
extends Object
implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.context.EnvironmentAware

Creates a WorkerFactory and Workers for a given namespace provided by WorkflowClient.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WorkersTemplate.RegisteredActivityInfo
static class	WorkersTemplate.RegisteredInfo
static class	WorkersTemplate.RegisteredNexusServiceInfo
static class	WorkersTemplate.RegisteredWorkflowInfo

Constructor Summary

Constructors

Constructor	Description
WorkersTemplate(NamespaceProperties namespaceProperties, ClientTemplate clientTemplate, List<io.temporal.common.interceptors.WorkerInterceptor> workerInterceptors, io.opentracing.Tracer tracer, TestWorkflowEnvironmentAdapter testWorkflowEnvironment, List<TemporalOptionsCustomizer<io.temporal.worker.WorkerFactoryOptions.Builder>> workerFactoryCustomizers, List<TemporalOptionsCustomizer<io.temporal.worker.WorkerOptions.Builder>> workerCustomizers, List<TemporalOptionsCustomizer<io.temporal.worker.WorkflowImplementationOptions.Builder>> workflowImplementationCustomizers)	Deprecated. Use constructor with plugins parameter
WorkersTemplate(NamespaceProperties namespaceProperties, ClientTemplate clientTemplate, List<io.temporal.common.interceptors.WorkerInterceptor> workerInterceptors, io.opentracing.Tracer tracer, TestWorkflowEnvironmentAdapter testWorkflowEnvironment, List<TemporalOptionsCustomizer<io.temporal.worker.WorkerFactoryOptions.Builder>> workerFactoryCustomizers, List<TemporalOptionsCustomizer<io.temporal.worker.WorkerOptions.Builder>> workerCustomizers, List<TemporalOptionsCustomizer<io.temporal.worker.WorkflowImplementationOptions.Builder>> workflowImplementationCustomizers, List<io.temporal.worker.WorkerPlugin> plugins)

Method Summary

Modifier and Type	Method	Description
NamespaceProperties	getNamespaceProperties()
Map<String,WorkersTemplate.RegisteredInfo>	getRegisteredInfo()	Return information on registered workflow and activity types per task queue
io.temporal.worker.WorkerFactory	getWorkerFactory()
Collection<io.temporal.worker.Worker>	getWorkers()
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
void	setEnvironment(org.springframework.core.env.Environment environment)

Methods inherited from class java.lang.Object

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

Constructor Details

WorkersTemplate

public WorkersTemplate(@Nonnull
 NamespaceProperties namespaceProperties,
 @Nullable
 ClientTemplate clientTemplate,
 @Nullable
 List<io.temporal.common.interceptors.WorkerInterceptor> workerInterceptors,
 @Nullable
 io.opentracing.Tracer tracer,
 @Nullable
 TestWorkflowEnvironmentAdapter testWorkflowEnvironment,
 @Nullable
 List<TemporalOptionsCustomizer<io.temporal.worker.WorkerFactoryOptions.Builder>> workerFactoryCustomizers,
 @Nullable
 List<TemporalOptionsCustomizer<io.temporal.worker.WorkerOptions.Builder>> workerCustomizers,
 @Nullable
 List<TemporalOptionsCustomizer<io.temporal.worker.WorkflowImplementationOptions.Builder>> workflowImplementationCustomizers,
 @Nullable
 List<io.temporal.worker.WorkerPlugin> plugins)

WorkersTemplate

@Deprecated
public WorkersTemplate(@Nonnull
 NamespaceProperties namespaceProperties,
 @Nullable
 ClientTemplate clientTemplate,
 @Nullable
 List<io.temporal.common.interceptors.WorkerInterceptor> workerInterceptors,
 @Nullable
 io.opentracing.Tracer tracer,
 @Nullable
 TestWorkflowEnvironmentAdapter testWorkflowEnvironment,
 @Nullable
 List<TemporalOptionsCustomizer<io.temporal.worker.WorkerFactoryOptions.Builder>> workerFactoryCustomizers,
 @Nullable
 List<TemporalOptionsCustomizer<io.temporal.worker.WorkerOptions.Builder>> workerCustomizers,
 @Nullable
 List<TemporalOptionsCustomizer<io.temporal.worker.WorkflowImplementationOptions.Builder>> workflowImplementationCustomizers)

Deprecated.

Use constructor with plugins parameter

Method Details

getNamespaceProperties

public NamespaceProperties getNamespaceProperties()

getWorkerFactory

public io.temporal.worker.WorkerFactory getWorkerFactory()

getWorkers

public Collection<io.temporal.worker.Worker> getWorkers()

getRegisteredInfo

@Experimental
public Map<String,WorkersTemplate.RegisteredInfo> getRegisteredInfo()

Return information on registered workflow and activity types per task queue

setBeanFactory

public void setBeanFactory(@Nonnull
 org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Throws:

org.springframework.beans.BeansException

setEnvironment

public void setEnvironment(@Nonnull
 org.springframework.core.env.Environment environment)

Specified by:

setEnvironment in interface org.springframework.context.EnvironmentAware