Package io.temporal.spring.boot.autoconfigure.template

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 java.lang.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, java.util.List<io.temporal.common.interceptors.WorkerInterceptor> workerInterceptors, io.opentracing.Tracer tracer, TestWorkflowEnvironmentAdapter testWorkflowEnvironment, java.util.List<TemporalOptionsCustomizer<io.temporal.worker.WorkerFactoryOptions.Builder>> workerFactoryCustomizers, java.util.List<TemporalOptionsCustomizer<io.temporal.worker.WorkerOptions.Builder>> workerCustomizers, java.util.List<TemporalOptionsCustomizer<io.temporal.worker.WorkflowImplementationOptions.Builder>> workflowImplementationCustomizers)	Deprecated. Use constructor with plugins parameter
WorkersTemplate(NamespaceProperties namespaceProperties, ClientTemplate clientTemplate, java.util.List<io.temporal.common.interceptors.WorkerInterceptor> workerInterceptors, io.opentracing.Tracer tracer, TestWorkflowEnvironmentAdapter testWorkflowEnvironment, java.util.List<TemporalOptionsCustomizer<io.temporal.worker.WorkerFactoryOptions.Builder>> workerFactoryCustomizers, java.util.List<TemporalOptionsCustomizer<io.temporal.worker.WorkerOptions.Builder>> workerCustomizers, java.util.List<TemporalOptionsCustomizer<io.temporal.worker.WorkflowImplementationOptions.Builder>> workflowImplementationCustomizers, java.util.List<io.temporal.worker.WorkerPlugin> plugins)

Method Summary

Modifier and Type	Method	Description
NamespaceProperties	getNamespaceProperties()
java.util.Map<java.lang.String,WorkersTemplate.RegisteredInfo>	getRegisteredInfo()	Return information on registered workflow and activity types per task queue
io.temporal.worker.WorkerFactory	getWorkerFactory()
java.util.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 Detail

WorkersTemplate

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

WorkersTemplate

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

Deprecated.

Use constructor with plugins parameter

Method Detail

getNamespaceProperties

public NamespaceProperties getNamespaceProperties()

getWorkerFactory

public io.temporal.worker.WorkerFactory getWorkerFactory()

getWorkers

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

getRegisteredInfo

@Experimental
public java.util.Map<java.lang.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