org.hawaiiframework.async.model

Class ExecutorConfigurationProperties

java.lang.Object

org.hawaiiframework.async.model.ExecutorConfigurationProperties

public class ExecutorConfigurationProperties
extends java.lang.Object

Configuration properties for the asynchronous execution. The properties consist of two parts:

1. Executors
2. Systems, containing Calls

From each of the executor configurations, a ThreadPoolTaskExecutor will be created. The default executor is the fallback for any task not specifically configured to an executor.

A system is a group of tasks, assumed to belong to a single system, for example a backend system. Both a system and a call can be assigned to an executor, where the task configuration takes precedence.

Note that any task not specifically assigned to an executor will default to the global default executor.

Since:

2.0.0

Author:

Rutger Lubbers, Paul Klos

Constructor Summary

Constructors

Constructor and Description
ExecutorConfigurationProperties()

Method Summary

Modifier and Type	Method and Description
void	addExecutor(ExecutorProperties executor) Convenience method to add properties for a single executor.
void	addSystem(SystemProperties system) Convenience method to add properties for a single system.
java.lang.Integer	getAsyncTimeoutExecutorPoolSize() Getter for the async task timeout executor pool size.
java.lang.String	getDefaultExecutor() Getter for the default executor.
java.lang.Integer	getDefaultTimeout() Getter for default timeout.
java.util.List<ExecutorProperties>	getExecutors() Getter for the executors.
SystemProperties	getSystemPropertiesForName(java.lang.String systemName) Retrieve the properties for the system with the given name.
java.util.List<SystemProperties>	getSystems() Getter for the systems.
java.lang.Integer	getTaskTimeout(java.lang.String taskName) Determine the timeout for a task.
void	setAsyncTimeoutExecutorPoolSize(java.lang.Integer asyncTimeoutExecutorPoolSize) Setter for the async task timeout executor pool size.
void	setDefaultExecutor(java.lang.String defaultExecutor) Setter for the default executor.
void	setDefaultTimeout(java.lang.Integer defaultTimeout) Setter for the default timeout.
void	setExecutors(java.util.List<ExecutorProperties> executors) Setter for the executors.
void	setSystems(java.util.List<SystemProperties> systems) Setter for the systems.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorConfigurationProperties

public ExecutorConfigurationProperties()

Method Detail

getDefaultExecutor

public java.lang.String getDefaultExecutor()

Getter for the default executor.

Returns:

the default executor

setDefaultExecutor

public void setDefaultExecutor(java.lang.String defaultExecutor)

Setter for the default executor.

Parameters:

defaultExecutor - the default executor

getDefaultTimeout

public java.lang.Integer getDefaultTimeout()

Getter for default timeout.

Returns:

the default timeout

setDefaultTimeout

public void setDefaultTimeout(java.lang.Integer defaultTimeout)

Setter for the default timeout.

Parameters:

defaultTimeout - the default timeout

getAsyncTimeoutExecutorPoolSize

public java.lang.Integer getAsyncTimeoutExecutorPoolSize()

Getter for the async task timeout executor pool size.

Returns:

the core pool size to use.

setAsyncTimeoutExecutorPoolSize

public void setAsyncTimeoutExecutorPoolSize(java.lang.Integer asyncTimeoutExecutorPoolSize)

Setter for the async task timeout executor pool size.

Parameters:

asyncTimeoutExecutorPoolSize - the core pool size to set.

getExecutors

public java.util.List<ExecutorProperties> getExecutors()

Getter for the executors.

Returns:

the executors

setExecutors

public void setExecutors(java.util.List<ExecutorProperties> executors)

Setter for the executors.

Parameters:

executors - the executors

addExecutor

public void addExecutor(ExecutorProperties executor)

Convenience method to add properties for a single executor.

Parameters:

executor - the executor properties

getSystems

public java.util.List<SystemProperties> getSystems()

Getter for the systems.

Returns:

the systems

setSystems

public void setSystems(java.util.List<SystemProperties> systems)

Setter for the systems.

Parameters:

systems - the systems

addSystem

public void addSystem(SystemProperties system)

Convenience method to add properties for a single system.

Parameters:

system - the system properties

getTaskTimeout

public java.lang.Integer getTaskTimeout(java.lang.String taskName)

Determine the timeout for a task.

The task name must be formatted as {system}.{task}. If a specific timeout is configured for the task, it is returned. Otherwise, the system's default timeout or the general default timeout is returned as a fallback value.

Parameters:

taskName - the task name

Returns:

the timeout, or null if the task or system doesn't exist

getSystemPropertiesForName

public SystemProperties getSystemPropertiesForName(java.lang.String systemName)

Retrieve the properties for the system with the given name.

Parameters:

systemName - the system name

Returns:

the properties