package org.dromara.common.job.config.properties;
|
|
import lombok.Getter;
|
import lombok.Setter;
|
import org.springframework.boot.context.properties.ConfigurationProperties;
|
import tech.powerjob.common.RemoteConstant;
|
import tech.powerjob.common.enums.Protocol;
|
import tech.powerjob.worker.common.constants.StoreStrategy;
|
import tech.powerjob.worker.core.processor.ProcessResult;
|
import tech.powerjob.worker.core.processor.WorkflowContext;
|
|
/**
|
* PowerJob properties configuration class.
|
*
|
* @author songyinyin
|
* @since 2020/7/26 16:37
|
*/
|
@ConfigurationProperties(prefix = "powerjob")
|
public class PowerJobProperties {
|
|
private final Worker worker = new Worker();
|
|
public Worker getWorker() {
|
return worker;
|
}
|
|
/**
|
* Powerjob worker configuration properties.
|
*/
|
@Setter
|
@Getter
|
public static class Worker {
|
|
/**
|
* Whether to enable PowerJob Worker
|
*/
|
private boolean enabled = true;
|
|
/**
|
* Name of application, String type. Total length of this property should be no more than 255
|
* characters. This is one of the required properties when registering a new application. This
|
* property should be assigned with the same value as what you entered for the appName.
|
*/
|
private String appName;
|
/**
|
* Akka port of Powerjob-worker, optional value. Default value of this property is 27777.
|
* If multiple PowerJob-worker nodes were deployed, different, unique ports should be assigned.
|
* Deprecated, please use 'port'
|
*/
|
@Deprecated
|
private int akkaPort = RemoteConstant.DEFAULT_WORKER_PORT;
|
/**
|
* port
|
*/
|
private Integer port;
|
/**
|
* Address(es) of Powerjob-server node(s). Ip:port or domain.
|
* Example of single Powerjob-server node:
|
* <p>
|
* 127.0.0.1:7700
|
* </p>
|
* Example of Powerjob-server cluster:
|
* <p>
|
* 192.168.0.10:7700,192.168.0.11:7700,192.168.0.12:7700
|
* </p>
|
*/
|
private String serverAddress;
|
|
private String serverName;
|
/**
|
* Protocol for communication between WORKER and server
|
*/
|
private Protocol protocol = Protocol.AKKA;
|
/**
|
* Local store strategy for H2 database. {@code disk} or {@code memory}.
|
*/
|
private StoreStrategy storeStrategy = StoreStrategy.DISK;
|
/**
|
* Max length of response result. Result that is longer than the value will be truncated.
|
* {@link ProcessResult} max length for #msg
|
*/
|
private int maxResultLength = 8192;
|
/**
|
* If allowLazyConnectServer is set as true, PowerJob worker allows launching without a direct connection to the server.
|
* allowLazyConnectServer is used for conditions that your have no powerjob-server in your develop env so you can't startup the application
|
*/
|
private boolean allowLazyConnectServer = false;
|
/**
|
* Max length of appended workflow context value length. Appended workflow context value that is longer than the value will be ignored.
|
* {@link WorkflowContext} max length for #appendedContextData
|
*/
|
private int maxAppendedWfContextLength = 8192;
|
|
private String tag;
|
/**
|
* Max numbers of LightTaskTacker
|
*/
|
private Integer maxLightweightTaskNum = 1024;
|
/**
|
* Max numbers of HeavyTaskTacker
|
*/
|
private Integer maxHeavyweightTaskNum = 64;
|
/**
|
* Interval(s) of worker health report
|
*/
|
private Integer healthReportInterval = 10;
|
|
}
|
}
|
