Class JobWorkerConfiguration

java.lang.Object

com.bluebell.greenhouse.platform.configuration.JobWorkerConfiguration

@Configuration
@EnableConfigurationProperties(JobSettings.class)
public class JobWorkerConfiguration
extends Object

Configures the bounded durable-job worker pool and process worker identity.

Version:

3.0.6

Author:

Stephen Prizio

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JOB_WORKER_EXECUTOR	Durable job executor bean name.
static final String	JOB_WORKER_ID	Durable job worker identity bean name.

Constructor Summary

Constructors

Constructor	Description
JobWorkerConfiguration()

Method Summary

Modifier and Type	Method	Description
Executor	jobWorkerExecutor(JobSettings jobSettings)	Builds the durable-job executor.
String	jobWorkerId()	Creates the stable identity for this application process.

Methods inherited from class Object

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

Field Details

JOB_WORKER_EXECUTOR

public static final String JOB_WORKER_EXECUTOR

Durable job executor bean name.

See Also:

• Constant Field Values

JOB_WORKER_ID

public static final String JOB_WORKER_ID

Durable job worker identity bean name.

See Also:

• Constant Field Values

Constructor Details

JobWorkerConfiguration

public JobWorkerConfiguration()

Method Details

jobWorkerExecutor

@Bean("jobWorkerExecutor")
public Executor jobWorkerExecutor(JobSettings jobSettings)

Builds the durable-job executor. The pool carries no local backlog: a claimed attempt either starts on a worker thread immediately or is rejected and returned to the queue, so a claim can never sit waiting without a heartbeat and lose its lease before it begins.

Parameters:

jobSettings - validated durable job settings

Returns:

configured executor

jobWorkerId

@Bean("jobWorkerId")
public String jobWorkerId()

Creates the stable identity for this application process.

Returns:

worker identifier