Package org.flowable.job.service.impl.asyncexecutor

Class AsyncJobExecutorConfiguration

java.lang.Object
org.flowable.job.service.impl.asyncexecutor.AsyncJobExecutorConfiguration
public class AsyncJobExecutorConfiguration extends Object
Author:
Filip Hrisafov

  • Field Details

    • globalAcquireLockEnabled

      protected boolean globalAcquireLockEnabled
      Whether global acquire lock should be used.

    • globalAcquireLockPrefix

      protected String globalAcquireLockPrefix
      The prefix that the runnable should use for the global acquire lock. Setting a different prefix allows differentiating different engines / executors without them competing for the same lock.

  • Constructor Details

    • AsyncJobExecutorConfiguration

      public AsyncJobExecutorConfiguration()

  • Method Details

    • isAsyncJobAcquisitionEnabled

      public boolean isAsyncJobAcquisitionEnabled()

    • setAsyncJobAcquisitionEnabled

      public void setAsyncJobAcquisitionEnabled(boolean asyncJobAcquisitionEnabled)

    • isTimerJobAcquisitionEnabled

      public boolean isTimerJobAcquisitionEnabled()

    • setTimerJobAcquisitionEnabled

      public void setTimerJobAcquisitionEnabled(boolean timerJobAcquisitionEnabled)

    • isResetExpiredJobEnabled

      public boolean isResetExpiredJobEnabled()

    • setResetExpiredJobEnabled

      public void setResetExpiredJobEnabled(boolean resetExpiredJobEnabled)

    • isUnlockOwnedJobs

      public boolean isUnlockOwnedJobs()

    • setUnlockOwnedJobs

      public void setUnlockOwnedJobs(boolean unlockOwnedJobs)

    • isTimerRunnableNeeded

      public boolean isTimerRunnableNeeded()

    • setTimerRunnableNeeded

      public void setTimerRunnableNeeded(boolean timerRunnableNeeded)

    • getAcquireRunnableThreadName

      public String getAcquireRunnableThreadName()

    • setAcquireRunnableThreadName

      public void setAcquireRunnableThreadName(String acquireRunnableThreadName)

    • getResetExpiredRunnableName

      public String getResetExpiredRunnableName()

    • setResetExpiredRunnableName

      public void setResetExpiredRunnableName(String resetExpiredRunnableName)

    • getMoveTimerExecutorPoolSize

      public int getMoveTimerExecutorPoolSize()

    • setMoveTimerExecutorPoolSize

      public void setMoveTimerExecutorPoolSize(int moveTimerExecutorPoolSize)

    • getMaxTimerJobsPerAcquisition

      public int getMaxTimerJobsPerAcquisition()

    • setMaxTimerJobsPerAcquisition

      public void setMaxTimerJobsPerAcquisition(int maxTimerJobsPerAcquisition)

    • getMaxAsyncJobsDuePerAcquisition

      public int getMaxAsyncJobsDuePerAcquisition()

    • setMaxAsyncJobsDuePerAcquisition

      public void setMaxAsyncJobsDuePerAcquisition(int maxAsyncJobsDuePerAcquisition)

    • getDefaultTimerJobAcquireWaitTime

      public Duration getDefaultTimerJobAcquireWaitTime()

    • setDefaultTimerJobAcquireWaitTime

      public void setDefaultTimerJobAcquireWaitTime(Duration defaultTimerJobAcquireWaitTime)

    • setDefaultTimerJobAcquireWaitTimeInMillis

      @Deprecated public void setDefaultTimerJobAcquireWaitTimeInMillis(int defaultTimerJobAcquireWaitTimeInMillis)
      Deprecated.

    • getDefaultAsyncJobAcquireWaitTime

      public Duration getDefaultAsyncJobAcquireWaitTime()

    • setDefaultAsyncJobAcquireWaitTime

      public void setDefaultAsyncJobAcquireWaitTime(Duration defaultAsyncJobAcquireWaitTime)

    • setDefaultAsyncJobAcquireWaitTimeInMillis

      @Deprecated public void setDefaultAsyncJobAcquireWaitTimeInMillis(int defaultAsyncJobAcquireWaitTimeInMillis)
      Deprecated.

    • getDefaultQueueSizeFullWaitTime

      public Duration getDefaultQueueSizeFullWaitTime()

    • setDefaultQueueSizeFullWaitTime

      public void setDefaultQueueSizeFullWaitTime(Duration defaultQueueSizeFullWaitTime)

    • setDefaultQueueSizeFullWaitTimeInMillis

      @Deprecated public void setDefaultQueueSizeFullWaitTimeInMillis(int defaultQueueSizeFullWaitTimeInMillis)
      Deprecated.

    • getLockOwner

      public String getLockOwner()

    • setLockOwner

      public void setLockOwner(String lockOwner)

    • getTimerLockTime

      public Duration getTimerLockTime()

    • setTimerLockTime

      public void setTimerLockTime(Duration timerLockTime)

    • setTimerLockTimeInMillis

      @Deprecated public void setTimerLockTimeInMillis(int timerLockTimeInMillis)
      Deprecated.

    • getAsyncJobLockTime

      public Duration getAsyncJobLockTime()

    • setAsyncJobLockTime

      public void setAsyncJobLockTime(Duration asyncJobLockTime)

    • setAsyncJobLockTimeInMillis

      @Deprecated public void setAsyncJobLockTimeInMillis(int asyncJobLockTimeInMillis)
      Deprecated.

    • isGlobalAcquireLockEnabled

      public boolean isGlobalAcquireLockEnabled()

    • setGlobalAcquireLockEnabled

      public void setGlobalAcquireLockEnabled(boolean globalAcquireLockEnabled)

    • getGlobalAcquireLockPrefix

      public String getGlobalAcquireLockPrefix()

    • setGlobalAcquireLockPrefix

      public void setGlobalAcquireLockPrefix(String globalAcquireLockPrefix)

    • getAsyncJobsGlobalLockWaitTime

      public Duration getAsyncJobsGlobalLockWaitTime()

    • setAsyncJobsGlobalLockWaitTime

      public void setAsyncJobsGlobalLockWaitTime(Duration asyncJobsGlobalLockWaitTime)

    • getAsyncJobsGlobalLockPollRate

      public Duration getAsyncJobsGlobalLockPollRate()

    • setAsyncJobsGlobalLockPollRate

      public void setAsyncJobsGlobalLockPollRate(Duration asyncJobsGlobalLockPollRate)

    • getAsyncJobsGlobalLockForceAcquireAfter

      public Duration getAsyncJobsGlobalLockForceAcquireAfter()

    • setAsyncJobsGlobalLockForceAcquireAfter

      public void setAsyncJobsGlobalLockForceAcquireAfter(Duration asyncJobsGlobalLockForceAcquireAfter)

    • getTimerLockWaitTime

      public Duration getTimerLockWaitTime()

    • setTimerLockWaitTime

      public void setTimerLockWaitTime(Duration timerLockWaitTime)

    • getTimerLockPollRate

      public Duration getTimerLockPollRate()

    • setTimerLockPollRate

      public void setTimerLockPollRate(Duration timerLockPollRate)

    • getTimerLockForceAcquireAfter

      public Duration getTimerLockForceAcquireAfter()

    • setTimerLockForceAcquireAfter

      public void setTimerLockForceAcquireAfter(Duration timerLockForceAcquireAfter)

    • getResetExpiredJobsInterval

      public Duration getResetExpiredJobsInterval()

    • setResetExpiredJobsInterval

      public void setResetExpiredJobsInterval(Duration resetExpiredJobsInterval)

    • getResetExpiredJobsPageSize

      public int getResetExpiredJobsPageSize()

    • setResetExpiredJobsPageSize

      public void setResetExpiredJobsPageSize(int resetExpiredJobsPageSize)

    • getTenantId

      public String getTenantId()

    • setTenantId

      public void setTenantId(String tenantId)