Package org.flowable.external.worker.config

Class DefaultFlowableWorkerContainerFactory

java.lang.Object
org.flowable.external.worker.config.DefaultFlowableWorkerContainerFactory
All Implemented Interfaces:
FlowableWorkerContainerFactory<WorkerJobListenerContainer>
public class DefaultFlowableWorkerContainerFactory extends Object implements FlowableWorkerContainerFactory<WorkerJobListenerContainer>
Author:
Filip Hrisafov

  • Field Details

    • externalWorkerClient

      protected ExternalWorkerClient externalWorkerClient

    • pollingInterval

      protected Duration pollingInterval

    • concurrency

      protected Integer concurrency

    • lockDuration

      protected Duration lockDuration

    • numberOfTasks

      protected Integer numberOfTasks

    • numberOfRetries

      protected Integer numberOfRetries

  • Constructor Details

    • DefaultFlowableWorkerContainerFactory

      public DefaultFlowableWorkerContainerFactory()

  • Method Details

    • setExternalWorkerClient

      public void setExternalWorkerClient(ExternalWorkerClient externalWorkerClient)

    • setPollingInterval

      public void setPollingInterval(Duration pollingInterval)
      Specify the container polling interval
      Parameters:
      pollingInterval - the polling interval for the container

    • setConcurrency

      public void setConcurrency(Integer concurrency)
      Specify the container concurrency
      Parameters:
      concurrency - the number of consumers to create

    • setLockDuration

      public void setLockDuration(Duration lockDuration)
      Specify the lock duration for the acquired jobs
      Parameters:
      lockDuration - the lock duration for the acquired jobs

    • setNumberOfTasks

      public void setNumberOfTasks(Integer numberOfTasks)
      Specify the amount of jobs that should be acquired
      Parameters:
      numberOfTasks - the amount of jobs that should be acquired

    • setNumberOfRetries

      public void setNumberOfRetries(Integer numberOfRetries)
      Specify the amount of retries when acquiring jobs
      Parameters:
      numberOfRetries - the amount of retries when acquiring jobs

    • createWorkerContainer

      public WorkerJobListenerContainer createWorkerContainer(FlowableWorkerEndpoint endpoint)
      Description copied from interface: FlowableWorkerContainerFactory
      Create a FlowableWorkerContainer for the given FlowableWorkerEndpoint.
      Specified by:
      createWorkerContainer in interface FlowableWorkerContainerFactory<WorkerJobListenerContainer>
      Parameters:
      endpoint - the endpoint to configure
      Returns:
      the created container