Package io.camunda.client.impl

Class CamundaClientBuilderImpl

java.lang.Object

io.camunda.client.impl.CamundaClientBuilderImpl

All Implemented Interfaces:

CamundaClientBuilder, CamundaClientConfiguration

public final class CamundaClientBuilderImpl
extends Object
implements CamundaClientBuilder, CamundaClientConfiguration

Field Summary

Fields

Modifier and Type	Field	Description
static final boolean	DEFAULT_CLIENT_SIDE_LOAD_BALANCING
static final String	DEFAULT_GATEWAY_ADDRESS
static final URI	DEFAULT_GRPC_ADDRESS
static final JobExceptionHandler	DEFAULT_JOB_EXCEPTION_HANDLER
static final Duration	DEFAULT_JOB_POLL_INTERVAL
static final Duration	DEFAULT_JOB_TIMEOUT
static final String	DEFAULT_JOB_WORKER_NAME_VAR
static final TenantFilter	DEFAULT_JOB_WORKER_TENANT_FILTER
static final List<String>	DEFAULT_JOB_WORKER_TENANT_IDS
static final Duration	DEFAULT_KEEP_ALIVE
static final int	DEFAULT_MAX_HTTP_CONNECTIONS
static final int	DEFAULT_MAX_JOBS_ACTIVE
static final int	DEFAULT_MAX_MESSAGE_SIZE
static final int	DEFAULT_MAX_METADATA_SIZE
static final Duration	DEFAULT_MESSAGE_TTL
static final int	DEFAULT_NUM_JOB_WORKER_EXECUTION_THREADS
static final boolean	DEFAULT_PREFER_REST_OVER_GRPC
static final boolean	DEFAULT_PREFIX_PHYSICAL_TENANT_PATH
static final Duration	DEFAULT_REQUEST_TIMEOUT
static final Duration	DEFAULT_REQUEST_TIMEOUT_OFFSET
static final URI	DEFAULT_REST_ADDRESS
static final boolean	DEFAULT_STREAM_ENABLED

Constructor Summary

Constructors

Constructor	Description
CamundaClientBuilderImpl()

Method Summary

Modifier and Type	Method	Description
CamundaClientBuilder	applyEnvironmentVariableOverrides(boolean applyEnvironmentVariableOverrides)	Allows to disable the mechanism to override some properties by ENVIRONMENT VARIABLES.
CamundaClient	build()
CamundaClientBuilder	caCertificatePath(String certificatePath)	Path to a root CA certificate to be used instead of the certificate in the default default store.
CamundaClientBuilder	credentialsProvider(CredentialsProvider credentialsProvider)	A custom CredentialsProvider which will be used to apply authentication credentials to requests.
CamundaClientBuilder	defaultJobPollInterval(Duration pollInterval)	The interval which a job worker is periodically polling for new jobs.
CamundaClientBuilder	defaultJobTimeout(Duration timeout)	The timeout which is used when none is provided for a job worker.
CamundaClientBuilder	defaultJobWorkerExceptionHandler(JobExceptionHandler jobExceptionHandler)	A custom retryBackoffSupplier allows the client to determine the default retry backoff strategy that every job worker will apply unless configured otherwise.
CamundaClientBuilder	defaultJobWorkerMaxJobsActive(int maxJobsActive)
CamundaClientBuilder	defaultJobWorkerName(String workerName)	The name of the worker which is used when none is set for a job worker.
CamundaClientBuilder	defaultJobWorkerStreamEnabled(boolean streamEnabled)	A custom streamEnabled allows the client to use job stream instead of job poll.
CamundaClientBuilder	defaultJobWorkerTenantFilter(TenantFilter tenantFilter)	The behavior to adopt when filtering jobs during activation by a given worker.
CamundaClientBuilder	defaultJobWorkerTenantIds(List<String> tenantIds)
CamundaClientBuilder	defaultMessageTimeToLive(Duration timeToLive)	The time-to-live which is used when none is provided for a message.
CamundaClientBuilder	defaultRequestTimeout(Duration requestTimeout)	The request timeout used if not overridden by the command.
CamundaClientBuilder	defaultRequestTimeoutOffset(Duration requestTimeoutOffset)	The request timeout client offset is used in commands where the CamundaClientBuilder.defaultRequestTimeout(Duration) is also passed to the server.
CamundaClientBuilder	defaultTenantId(String tenantId)
String	getCaCertificatePath()
List<org.apache.hc.client5.http.async.AsyncExecChainHandler>	getChainHandlers()
CredentialsProvider	getCredentialsProvider()
Duration	getDefaultJobPollInterval()
Duration	getDefaultJobTimeout()
JobExceptionHandler	getDefaultJobWorkerExceptionHandler()
int	getDefaultJobWorkerMaxJobsActive()
String	getDefaultJobWorkerName()
boolean	getDefaultJobWorkerStreamEnabled()
TenantFilter	getDefaultJobWorkerTenantFilter()
List<String>	getDefaultJobWorkerTenantIds()
Duration	getDefaultMessageTimeToLive()
Duration	getDefaultRequestTimeout()
Duration	getDefaultRequestTimeoutOffset()
String	getDefaultTenantId()
URI	getGrpcAddress()
List<io.grpc.ClientInterceptor>	getInterceptors()
JsonMapper	getJsonMapper()
Duration	getKeepAlive()
int	getMaxHttpConnections()
int	getMaxMessageSize()
int	getMaxMetadataSize()
int	getNumJobWorkerExecutionThreads()
String	getOverrideAuthority()
String	getPhysicalTenantId()
URI	getRestAddress()
CamundaClientBuilder	grpcAddress(URI grpcAddress)
ExecutorService	jobHandlingExecutor()
CamundaClientBuilder	jobHandlingExecutor(ExecutorService executor, boolean takeOwnership)	Allows passing a custom executor service that will be used for handling jobs (i.e. executing the JobHandler).
ScheduledExecutorService	jobWorkerExecutor()
CamundaClientBuilder	jobWorkerExecutor(ScheduledExecutorService executor, boolean takeOwnership)	Identical behavior as CamundaClientBuilder.jobWorkerSchedulingExecutor(ScheduledExecutorService,boolean).
ScheduledExecutorService	jobWorkerSchedulingExecutor()
CamundaClientBuilder	jobWorkerSchedulingExecutor(ScheduledExecutorService executor, boolean takeOwnership)	Allows passing a custom scheduled executor service that will be used for scheduling job worker tasks such as polling for new jobs.
CamundaClientBuilder	keepAlive(Duration keepAlive)	Time interval between keep alive messages sent to the gateway.
CamundaClientBuilder	maxHttpConnections(int maxConnections)	Sets the maximum number of concurrent HTTP connections the client can open.
CamundaClientBuilder	maxMessageSize(int maxMessageSize)	A custom maxMessageSize allows the client to receive larger or smaller responses from Camunda.
CamundaClientBuilder	maxMetadataSize(int maxMetadataSize)	A custom maxMetadataSize allows the client to receive larger or smaller response headers from Camunda.
CamundaClientBuilder	numJobWorkerExecutionThreads(int numSubscriptionThreads)
CamundaClientBuilder	overrideAuthority(String authority)	Overrides the authority used with TLS virtual hosting.
boolean	ownsJobHandlingExecutor()
boolean	ownsJobWorkerExecutor()
boolean	ownsJobWorkerSchedulingExecutor()
CamundaClientBuilder	physicalTenantId(String physicalTenantId)
boolean	preferRestOverGrpc()
CamundaClientBuilder	preferRestOverGrpc(boolean preferRestOverGrpc)	If true, will prefer to use REST over gRPC for calls which can be done over both REST and gRPC.
boolean	prefixPhysicalTenantPath()
CamundaClientBuilder	prefixPhysicalTenantPath(boolean prefixPhysicalTenantPath)	Controls whether the client prefixes the REST base path with /physical-tenants/<id> when a physical tenant id is set (default true).
CamundaClientBuilder	restAddress(URI restAddress)
String	toString()
boolean	useClientSideLoadBalancing()
CamundaClientBuilder	useClientSideLoadBalancing(boolean useClientSideLoadBalancing)	If enabled, the client will use DNS-based name resolution and balance across all addresses.
boolean	useDefaultRetryPolicy()
CamundaClientBuilder	useDefaultRetryPolicy(boolean useDefaultRetryPolicy)	If enabled, the client will make use of the default retry policy defined.
CamundaClientBuilder	withChainHandlers(org.apache.hc.client5.http.async.AsyncExecChainHandler... chainHandler)	Custom implementations of the Apache HttpClient AsyncExecChainHandler middleware API.
CamundaClientBuilderImpl	withConfiguration(CamundaClientConfiguration configuration)	Sets the configuration from a CamundaClientConfiguration object.
CamundaClientBuilder	withInterceptors(io.grpc.ClientInterceptor... interceptors)	Custom implementations of the gRPC ClientInterceptor middleware API.
CamundaClientBuilder	withJsonMapper(JsonMapper jsonMapper)
CamundaClientBuilder	withProperties(Properties properties)	Sets all the properties from a Properties object.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.camunda.client.CamundaClientBuilder

jobHandlingExecutor, jobWorkerExecutor, jobWorkerSchedulingExecutor

Field Details

DEFAULT_GATEWAY_ADDRESS

public static final String DEFAULT_GATEWAY_ADDRESS

See Also:

• Constant Field Values

DEFAULT_GRPC_ADDRESS

public static final URI DEFAULT_GRPC_ADDRESS

DEFAULT_REST_ADDRESS

public static final URI DEFAULT_REST_ADDRESS

DEFAULT_JOB_WORKER_NAME_VAR

public static final String DEFAULT_JOB_WORKER_NAME_VAR

See Also:

• Constant Field Values

DEFAULT_MESSAGE_TTL

public static final Duration DEFAULT_MESSAGE_TTL

DEFAULT_PREFER_REST_OVER_GRPC

public static final boolean DEFAULT_PREFER_REST_OVER_GRPC

See Also:

• Constant Field Values

DEFAULT_PREFIX_PHYSICAL_TENANT_PATH

public static final boolean DEFAULT_PREFIX_PHYSICAL_TENANT_PATH

See Also:

• Constant Field Values

DEFAULT_NUM_JOB_WORKER_EXECUTION_THREADS

public static final int DEFAULT_NUM_JOB_WORKER_EXECUTION_THREADS

See Also:

• Constant Field Values

DEFAULT_MAX_MESSAGE_SIZE

public static final int DEFAULT_MAX_MESSAGE_SIZE

See Also:

• Constant Field Values

DEFAULT_MAX_METADATA_SIZE

public static final int DEFAULT_MAX_METADATA_SIZE

See Also:

• Constant Field Values

DEFAULT_KEEP_ALIVE

public static final Duration DEFAULT_KEEP_ALIVE

DEFAULT_REQUEST_TIMEOUT

public static final Duration DEFAULT_REQUEST_TIMEOUT

DEFAULT_REQUEST_TIMEOUT_OFFSET

public static final Duration DEFAULT_REQUEST_TIMEOUT_OFFSET

DEFAULT_JOB_WORKER_TENANT_IDS

public static final List<String> DEFAULT_JOB_WORKER_TENANT_IDS

DEFAULT_JOB_WORKER_TENANT_FILTER

public static final TenantFilter DEFAULT_JOB_WORKER_TENANT_FILTER

DEFAULT_JOB_TIMEOUT

public static final Duration DEFAULT_JOB_TIMEOUT

DEFAULT_MAX_JOBS_ACTIVE

public static final int DEFAULT_MAX_JOBS_ACTIVE

See Also:

• Constant Field Values

DEFAULT_JOB_POLL_INTERVAL

public static final Duration DEFAULT_JOB_POLL_INTERVAL

DEFAULT_STREAM_ENABLED

public static final boolean DEFAULT_STREAM_ENABLED

See Also:

• Constant Field Values

DEFAULT_MAX_HTTP_CONNECTIONS

public static final int DEFAULT_MAX_HTTP_CONNECTIONS

See Also:

• Constant Field Values

DEFAULT_JOB_EXCEPTION_HANDLER

public static final JobExceptionHandler DEFAULT_JOB_EXCEPTION_HANDLER

DEFAULT_CLIENT_SIDE_LOAD_BALANCING

public static final boolean DEFAULT_CLIENT_SIDE_LOAD_BALANCING

See Also:

• Constant Field Values

Constructor Details

CamundaClientBuilderImpl

public CamundaClientBuilderImpl()

Method Details

getRestAddress

public URI getRestAddress()

Specified by:

getRestAddress in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.restAddress(URI)

getGrpcAddress

public URI getGrpcAddress()

Specified by:

getGrpcAddress in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.grpcAddress(URI)

getDefaultTenantId

public String getDefaultTenantId()

Specified by:

getDefaultTenantId in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultTenantId(String)

getPhysicalTenantId

public String getPhysicalTenantId()

Specified by:

getPhysicalTenantId in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.physicalTenantId(String)

prefixPhysicalTenantPath

public boolean prefixPhysicalTenantPath()

Specified by:

prefixPhysicalTenantPath in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.prefixPhysicalTenantPath(boolean)

getDefaultJobWorkerTenantIds

public List<String> getDefaultJobWorkerTenantIds()

Specified by:

getDefaultJobWorkerTenantIds in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultJobWorkerTenantIds(List)

getDefaultJobWorkerTenantFilter

public TenantFilter getDefaultJobWorkerTenantFilter()

Specified by:

getDefaultJobWorkerTenantFilter in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultJobWorkerTenantFilter(TenantFilter)

getNumJobWorkerExecutionThreads

public int getNumJobWorkerExecutionThreads()

Specified by:

getNumJobWorkerExecutionThreads in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.numJobWorkerExecutionThreads(int)

getDefaultJobWorkerMaxJobsActive

public int getDefaultJobWorkerMaxJobsActive()

Specified by:

getDefaultJobWorkerMaxJobsActive in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultJobWorkerMaxJobsActive(int)

getDefaultJobWorkerName

public String getDefaultJobWorkerName()

Specified by:

getDefaultJobWorkerName in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultJobWorkerName(String)

getDefaultJobTimeout

public Duration getDefaultJobTimeout()

Specified by:

getDefaultJobTimeout in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultJobTimeout(Duration)

getDefaultJobPollInterval

public Duration getDefaultJobPollInterval()

Specified by:

getDefaultJobPollInterval in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultJobPollInterval(Duration)

getDefaultMessageTimeToLive

public Duration getDefaultMessageTimeToLive()

Specified by:

getDefaultMessageTimeToLive in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultMessageTimeToLive(Duration)

getDefaultRequestTimeout

public Duration getDefaultRequestTimeout()

Specified by:

getDefaultRequestTimeout in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultRequestTimeout(Duration)

getDefaultRequestTimeoutOffset

public Duration getDefaultRequestTimeoutOffset()

Specified by:

getDefaultRequestTimeoutOffset in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultRequestTimeoutOffset(Duration)

getCaCertificatePath

public String getCaCertificatePath()

Specified by:

getCaCertificatePath in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.caCertificatePath(String)

getCredentialsProvider

public CredentialsProvider getCredentialsProvider()

Specified by:

getCredentialsProvider in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.credentialsProvider(CredentialsProvider)

getKeepAlive

public Duration getKeepAlive()

Specified by:

getKeepAlive in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.keepAlive(Duration)

getInterceptors

public List<io.grpc.ClientInterceptor> getInterceptors()

Specified by:

getInterceptors in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.withInterceptors(ClientInterceptor...)

getChainHandlers

public List<org.apache.hc.client5.http.async.AsyncExecChainHandler> getChainHandlers()

Specified by:

getChainHandlers in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.withChainHandlers(AsyncExecChainHandler...)

getJsonMapper

public JsonMapper getJsonMapper()

Specified by:

getJsonMapper in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.withJsonMapper(JsonMapper)

getOverrideAuthority

public String getOverrideAuthority()

Specified by:

getOverrideAuthority in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.overrideAuthority(String)

getMaxMessageSize

public int getMaxMessageSize()

Specified by:

getMaxMessageSize in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.maxMessageSize(int)

getMaxMetadataSize

public int getMaxMetadataSize()

Specified by:

getMaxMetadataSize in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.maxMetadataSize(int)

jobWorkerExecutor

public ScheduledExecutorService jobWorkerExecutor()

Specified by:

jobWorkerExecutor in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.jobWorkerExecutor(ScheduledExecutorService, boolean)

ownsJobWorkerExecutor

public boolean ownsJobWorkerExecutor()

Specified by:

ownsJobWorkerExecutor in interface CamundaClientConfiguration

jobWorkerSchedulingExecutor

public ScheduledExecutorService jobWorkerSchedulingExecutor()

Specified by:

jobWorkerSchedulingExecutor in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.jobWorkerSchedulingExecutor(ScheduledExecutorService, boolean)

ownsJobWorkerSchedulingExecutor

public boolean ownsJobWorkerSchedulingExecutor()

Specified by:

ownsJobWorkerSchedulingExecutor in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.jobWorkerSchedulingExecutor(ScheduledExecutorService, boolean)

jobHandlingExecutor

public ExecutorService jobHandlingExecutor()

Specified by:

jobHandlingExecutor in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.jobHandlingExecutor(ExecutorService, boolean)

ownsJobHandlingExecutor

public boolean ownsJobHandlingExecutor()

Specified by:

ownsJobHandlingExecutor in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.jobHandlingExecutor(ExecutorService, boolean)

getDefaultJobWorkerStreamEnabled

public boolean getDefaultJobWorkerStreamEnabled()

Specified by:

getDefaultJobWorkerStreamEnabled in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultJobWorkerStreamEnabled(boolean)

useDefaultRetryPolicy

public boolean useDefaultRetryPolicy()

Specified by:

useDefaultRetryPolicy in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.useDefaultRetryPolicy(boolean)

getDefaultJobWorkerExceptionHandler

public JobExceptionHandler getDefaultJobWorkerExceptionHandler()

Specified by:

getDefaultJobWorkerExceptionHandler in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.defaultJobWorkerExceptionHandler(JobExceptionHandler)

preferRestOverGrpc

public boolean preferRestOverGrpc()

Specified by:

preferRestOverGrpc in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.preferRestOverGrpc(boolean)

getMaxHttpConnections

public int getMaxHttpConnections()

Specified by:

getMaxHttpConnections in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.maxHttpConnections(int)

useClientSideLoadBalancing

public boolean useClientSideLoadBalancing()

Specified by:

useClientSideLoadBalancing in interface CamundaClientConfiguration

See Also:

• CamundaClientBuilder.useClientSideLoadBalancing(boolean)

withProperties

public CamundaClientBuilder withProperties(Properties properties)

Description copied from interface: CamundaClientBuilder

Sets all the properties from a Properties object. Can be used to configure the client from a properties file.

See ClientProperties for valid property names.

Specified by:

withProperties in interface CamundaClientBuilder

withConfiguration

public CamundaClientBuilderImpl withConfiguration(CamundaClientConfiguration configuration)

Description copied from interface: CamundaClientBuilder

Sets the configuration from a CamundaClientConfiguration object. Can be used to configure a client from a base configuration.

Specified by:

withConfiguration in interface CamundaClientBuilder

applyEnvironmentVariableOverrides

public CamundaClientBuilder applyEnvironmentVariableOverrides(boolean applyEnvironmentVariableOverrides)

Description copied from interface: CamundaClientBuilder

Allows to disable the mechanism to override some properties by ENVIRONMENT VARIABLES. This is useful if a client shall be constructed for test cases or in an environment that wants to fully control properties (like Spring Boot).

The default value is true.

Specified by:

applyEnvironmentVariableOverrides in interface CamundaClientBuilder

restAddress

public CamundaClientBuilder restAddress(URI restAddress)

Specified by:

restAddress in interface CamundaClientBuilder

Parameters:

restAddress - the REST API address of a gateway that the client can connect to. The address must be an absolute URL, including the scheme.

The default value is https://0.0.0.0:8080.

grpcAddress

public CamundaClientBuilder grpcAddress(URI grpcAddress)

Specified by:

grpcAddress in interface CamundaClientBuilder

Parameters:

grpcAddress - the gRPC address of a gateway that the client can connect to. The address must be an absolute URL, including the scheme.

The default value is https://0.0.0.0:26500.

defaultTenantId

public CamundaClientBuilder defaultTenantId(String tenantId)

Specified by:

defaultTenantId in interface CamundaClientBuilder

Parameters:

tenantId - the tenant identifier which is used for tenant-aware commands when no tenant identifier is set. The default value is CommandWithTenantStep.DEFAULT_TENANT_IDENTIFIER.

physicalTenantId

public CamundaClientBuilder physicalTenantId(String physicalTenantId)

Specified by:

physicalTenantId in interface CamundaClientBuilder

Parameters:

physicalTenantId - the physical tenant identifier sent as the Camunda-Physical-Tenant gRPC metadata header on every outgoing call. When null the header is omitted and the gateway applies its own default.

prefixPhysicalTenantPath

public CamundaClientBuilder prefixPhysicalTenantPath(boolean prefixPhysicalTenantPath)

Description copied from interface: CamundaClientBuilder

Controls whether the client prefixes the REST base path with /physical-tenants/<id> when a physical tenant id is set (default true). Set to false to use the configured REST address verbatim — e.g. when a reverse proxy or a custom path layout already routes to the physical tenant. Has no effect on the gRPC Camunda-Physical-Tenant header, which is always sent when a physical tenant id is set.

Specified by:

prefixPhysicalTenantPath in interface CamundaClientBuilder

Parameters:

prefixPhysicalTenantPath - whether to auto-prefix the REST base path per physical tenant

defaultJobWorkerTenantIds

public CamundaClientBuilder defaultJobWorkerTenantIds(List<String> tenantIds)

Specified by:

defaultJobWorkerTenantIds in interface CamundaClientBuilder

Parameters:

tenantIds - the tenant identifiers which are used for job-activation commands when no tenant identifiers are set. The default value contains only CommandWithTenantStep.DEFAULT_TENANT_IDENTIFIER.

defaultJobWorkerTenantFilter

public CamundaClientBuilder defaultJobWorkerTenantFilter(TenantFilter tenantFilter)

Description copied from interface: CamundaClientBuilder

The behavior to adopt when filtering jobs during activation by a given worker. See TenantFilter for possible values. The default value is TenantFilter.PROVIDED.

Specified by:

defaultJobWorkerTenantFilter in interface CamundaClientBuilder

defaultJobWorkerMaxJobsActive

public CamundaClientBuilder defaultJobWorkerMaxJobsActive(int maxJobsActive)

Specified by:

defaultJobWorkerMaxJobsActive in interface CamundaClientBuilder

Parameters:

maxJobsActive - Default value for JobWorkerBuilderStep1.JobWorkerBuilderStep3.maxJobsActive(int). Default value is 32.

numJobWorkerExecutionThreads

public CamundaClientBuilder numJobWorkerExecutionThreads(int numSubscriptionThreads)

Specified by:

numJobWorkerExecutionThreads in interface CamundaClientBuilder

Parameters:

numSubscriptionThreads - The number of threads for invocation of job workers. Default value is 1. Setting this value to 0 causes the client to reuse the scheduled executor for job handling (backward compatibility behavior).

jobWorkerExecutor

public CamundaClientBuilder jobWorkerExecutor(ScheduledExecutorService executor,
 boolean takeOwnership)

Description copied from interface: CamundaClientBuilder

Identical behavior as CamundaClientBuilder.jobWorkerSchedulingExecutor(ScheduledExecutorService,boolean). Replaced in favor of more fine-grained configuration of job worker executors.

Specified by:

jobWorkerExecutor in interface CamundaClientBuilder

jobWorkerSchedulingExecutor

public CamundaClientBuilder jobWorkerSchedulingExecutor(ScheduledExecutorService executor,
 boolean takeOwnership)

Description copied from interface: CamundaClientBuilder

Allows passing a custom scheduled executor service that will be used for scheduling job worker tasks such as polling for new jobs.

Note that job handling (i.e. executing the JobHandler) is done on a separate executor configured via CamundaClientBuilder.jobHandlingExecutor(ExecutorService, boolean).

If no job handling executor is provided, this scheduling executor will also be used for job handling. If no executor is provided here, a default scheduled executor will be created.

Specified by:

jobWorkerSchedulingExecutor in interface CamundaClientBuilder

Parameters:

executor - an executor service to use for scheduling job worker tasks

takeOwnership - if true, the executor will be closed when the client is closed otherwise, it's up to the caller to manage its lifecycle

See Also:

• CamundaClientBuilder.jobHandlingExecutor(ExecutorService, boolean)

jobHandlingExecutor

public CamundaClientBuilder jobHandlingExecutor(ExecutorService executor,
 boolean takeOwnership)

Description copied from interface: CamundaClientBuilder

Allows passing a custom executor service that will be used for handling jobs (i.e. executing the JobHandler). This executor is separate from the scheduling executor configured via CamundaClientBuilder.jobWorkerSchedulingExecutor(ScheduledExecutorService, boolean).

If no executor is provided here, the scheduling executor will also be used for job handling.

When non-null, this setting override CamundaClientBuilder.numJobWorkerExecutionThreads(int).

Specified by:

jobHandlingExecutor in interface CamundaClientBuilder

Parameters:

executor - an executor service to use for handling jobs

takeOwnership - if true, the executor will be closed when the client is closed otherwise, it's up to the caller to manage its lifecycle

defaultJobWorkerName

public CamundaClientBuilder defaultJobWorkerName(String workerName)

Description copied from interface: CamundaClientBuilder

The name of the worker which is used when none is set for a job worker. Default is 'default'.

Specified by:

defaultJobWorkerName in interface CamundaClientBuilder

defaultJobTimeout

public CamundaClientBuilder defaultJobTimeout(Duration timeout)

Description copied from interface: CamundaClientBuilder

The timeout which is used when none is provided for a job worker. Default is 5 minutes.

Specified by:

defaultJobTimeout in interface CamundaClientBuilder

defaultJobPollInterval

public CamundaClientBuilder defaultJobPollInterval(Duration pollInterval)

Description copied from interface: CamundaClientBuilder

The interval which a job worker is periodically polling for new jobs. Default is 100 milliseconds.

Specified by:

defaultJobPollInterval in interface CamundaClientBuilder

defaultMessageTimeToLive

public CamundaClientBuilder defaultMessageTimeToLive(Duration timeToLive)

Description copied from interface: CamundaClientBuilder

The time-to-live which is used when none is provided for a message. Default is 1 hour.

Specified by:

defaultMessageTimeToLive in interface CamundaClientBuilder

defaultRequestTimeout

public CamundaClientBuilder defaultRequestTimeout(Duration requestTimeout)

Description copied from interface: CamundaClientBuilder

The request timeout used if not overridden by the command. Default is 10 seconds.

Specified by:

defaultRequestTimeout in interface CamundaClientBuilder

defaultRequestTimeoutOffset

public CamundaClientBuilder defaultRequestTimeoutOffset(Duration requestTimeoutOffset)

Description copied from interface: CamundaClientBuilder

The request timeout client offset is used in commands where the CamundaClientBuilder.defaultRequestTimeout(Duration) is also passed to the server. This ensures that the client timeout does not occur before the server timeout.

The client-side timeout for these commands is calculated as the sum of defaultRequestTimeout and defaultRequestTimeoutOffset.

Default is 1 second.

Specified by:

defaultRequestTimeoutOffset in interface CamundaClientBuilder

caCertificatePath

public CamundaClientBuilder caCertificatePath(String certificatePath)

Description copied from interface: CamundaClientBuilder

Path to a root CA certificate to be used instead of the certificate in the default default store.

Specified by:

caCertificatePath in interface CamundaClientBuilder

credentialsProvider

public CamundaClientBuilder credentialsProvider(CredentialsProvider credentialsProvider)

Description copied from interface: CamundaClientBuilder

A custom CredentialsProvider which will be used to apply authentication credentials to requests.

Specified by:

credentialsProvider in interface CamundaClientBuilder

keepAlive

public CamundaClientBuilder keepAlive(Duration keepAlive)

Description copied from interface: CamundaClientBuilder

Time interval between keep alive messages sent to the gateway. The default is 45 seconds.

Specified by:

keepAlive in interface CamundaClientBuilder

withInterceptors

public CamundaClientBuilder withInterceptors(io.grpc.ClientInterceptor... interceptors)

Description copied from interface: CamundaClientBuilder

Custom implementations of the gRPC ClientInterceptor middleware API. The interceptors will be applied to every gRPC call that the client makes. More details can be found at invalid input: '{@link <a href="https://grpc.io/docs/guides/interceptors/">grpc.io</a>'}.

Specified by:

withInterceptors in interface CamundaClientBuilder

withChainHandlers

public CamundaClientBuilder withChainHandlers(org.apache.hc.client5.http.async.AsyncExecChainHandler... chainHandler)

Description copied from interface: CamundaClientBuilder

Custom implementations of the Apache HttpClient AsyncExecChainHandler middleware API. The middleware implementations will be called on every REST API call that the client makes.

Specified by:

withChainHandlers in interface CamundaClientBuilder

withJsonMapper

public CamundaClientBuilder withJsonMapper(JsonMapper jsonMapper)

Specified by:

withJsonMapper in interface CamundaClientBuilder

overrideAuthority

public CamundaClientBuilder overrideAuthority(String authority)

Description copied from interface: CamundaClientBuilder

Overrides the authority used with TLS virtual hosting. Specifically, to override hostname verification in the TLS handshake. It does not change what host is actually connected to.

This method is intended for testing, but may safely be used outside of tests as an alternative to DNS overrides.

This setting does nothing if a plaintext connection is used.

Specified by:

overrideAuthority in interface CamundaClientBuilder

Parameters:

authority - The alternative authority to use, commonly in the form host or host:port

maxMessageSize

public CamundaClientBuilder maxMessageSize(int maxMessageSize)

Description copied from interface: CamundaClientBuilder

A custom maxMessageSize allows the client to receive larger or smaller responses from Camunda. Technically, it specifies the maxInboundMessageSize of the gRPC channel. The default is 5242880 = 5MB.

Specified by:

maxMessageSize in interface CamundaClientBuilder

maxMetadataSize

public CamundaClientBuilder maxMetadataSize(int maxMetadataSize)

Description copied from interface: CamundaClientBuilder

A custom maxMetadataSize allows the client to receive larger or smaller response headers from Camunda. Technically, it specifies the maxInboundMetadataSize of the gRPC channel. The default is 16384 = 16KB .

Specified by:

maxMetadataSize in interface CamundaClientBuilder

defaultJobWorkerStreamEnabled

public CamundaClientBuilder defaultJobWorkerStreamEnabled(boolean streamEnabled)

Description copied from interface: CamundaClientBuilder

A custom streamEnabled allows the client to use job stream instead of job poll. The default value is set as enabled.

Specified by:

defaultJobWorkerStreamEnabled in interface CamundaClientBuilder

useDefaultRetryPolicy

public CamundaClientBuilder useDefaultRetryPolicy(boolean useDefaultRetryPolicy)

Description copied from interface: CamundaClientBuilder

If enabled, the client will make use of the default retry policy defined. False by default.

NOTE: the default retry policy is taken from the gateway-service-config.json in the io.camunda:zeebe-gateway-protocol-impl JAR.

Specified by:

useDefaultRetryPolicy in interface CamundaClientBuilder

preferRestOverGrpc

public CamundaClientBuilder preferRestOverGrpc(boolean preferRestOverGrpc)

Description copied from interface: CamundaClientBuilder

If true, will prefer to use REST over gRPC for calls which can be done over both REST and gRPC. The default value is true (REST is preferred).

NOTE: job streaming is only supported via gRPC

Specified by:

preferRestOverGrpc in interface CamundaClientBuilder

Parameters:

preferRestOverGrpc - if true, the client will use REST instead of gRPC whenever possible

useClientSideLoadBalancing

public CamundaClientBuilder useClientSideLoadBalancing(boolean useClientSideLoadBalancing)

Description copied from interface: CamundaClientBuilder

If enabled, the client will use DNS-based name resolution and balance across all addresses. This allows the client to distribute requests across multiple gateway instances resolved by DNS without requiring an external load balancer.

Default is false.

Specified by:

useClientSideLoadBalancing in interface CamundaClientBuilder

Parameters:

useClientSideLoadBalancing - if true, enables DNS resolution and randomized load balancing

maxHttpConnections

public CamundaClientBuilder maxHttpConnections(int maxConnections)

Description copied from interface: CamundaClientBuilder

Sets the maximum number of concurrent HTTP connections the client can open.

Specified by:

maxHttpConnections in interface CamundaClientBuilder

defaultJobWorkerExceptionHandler

public CamundaClientBuilder defaultJobWorkerExceptionHandler(JobExceptionHandler jobExceptionHandler)

Description copied from interface: CamundaClientBuilder

A custom retryBackoffSupplier allows the client to determine the default retry backoff strategy that every job worker will apply unless configured otherwise. By default, a static retry backoff of PT0S is used.

Specified by:

defaultJobWorkerExceptionHandler in interface CamundaClientBuilder

Parameters:

jobExceptionHandler - the retry backoff supplier to retrieve the retry backoff for every fail job command

Returns:

this builder for chaining

build

public CamundaClient build()

Specified by:

build in interface CamundaClientBuilder

Returns:

a new CamundaClient with the provided configuration options.

toString

public String toString()

Overrides:

toString in class Object