Package com.flowable.platform.engine.impl.sandbox.longrunning

Class LongRunningCommandInterruptor

java.lang.Object
org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor
com.flowable.platform.engine.impl.sandbox.longrunning.LongRunningCommandInterruptor
All Implemented Interfaces:
org.flowable.common.engine.impl.agenda.AgendaOperationExecutionListener, org.flowable.common.engine.impl.interceptor.CommandInterceptor
public class LongRunningCommandInterruptor extends org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor implements org.flowable.common.engine.impl.agenda.AgendaOperationExecutionListener
Author:
Filip Hrisafov

  • Field Summary

    Fields inherited from class org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor

    next

  • Constructor Summary

    Constructors
    Constructor
    Description
    LongRunningCommandInterruptor()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    afterAll(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
     
    void
    afterExecute(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, Runnable runnable)
     
    void
    afterExecuteException(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, Runnable runnable, Throwable error)
     
    void
    beforeAll(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
     
    void
    beforeExecute(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, Runnable runnable)
     
    <T> T
    execute(org.flowable.common.engine.impl.interceptor.CommandConfig config, org.flowable.common.engine.impl.interceptor.Command<T> command, org.flowable.common.engine.impl.interceptor.CommandExecutor commandExecutor)
     
    protected Duration
    getMaxCommandDuration(String tenantId, PlatformEngineConfiguration platformEngineConfiguration)
     
    protected Duration
    getMaxCommandDuration(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
     
    protected void
    validateRuntimeWithinLimits(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
     

    Methods inherited from class org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor

    getNext, setNext

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • LongRunningCommandInterruptor

      public LongRunningCommandInterruptor()

  • Method Details

    • execute

      public <T> T execute(org.flowable.common.engine.impl.interceptor.CommandConfig config, org.flowable.common.engine.impl.interceptor.Command<T> command, org.flowable.common.engine.impl.interceptor.CommandExecutor commandExecutor)
      Specified by:
      execute in interface org.flowable.common.engine.impl.interceptor.CommandInterceptor

    • beforeAll

      public void beforeAll(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
      Specified by:
      beforeAll in interface org.flowable.common.engine.impl.agenda.AgendaOperationExecutionListener

    • beforeExecute

      public void beforeExecute(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, Runnable runnable)
      Specified by:
      beforeExecute in interface org.flowable.common.engine.impl.agenda.AgendaOperationExecutionListener

    • afterExecute

      public void afterExecute(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, Runnable runnable)
      Specified by:
      afterExecute in interface org.flowable.common.engine.impl.agenda.AgendaOperationExecutionListener

    • afterExecuteException

      public void afterExecuteException(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, Runnable runnable, Throwable error)
      Specified by:
      afterExecuteException in interface org.flowable.common.engine.impl.agenda.AgendaOperationExecutionListener

    • afterAll

      public void afterAll(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
      Specified by:
      afterAll in interface org.flowable.common.engine.impl.agenda.AgendaOperationExecutionListener

    • validateRuntimeWithinLimits

      protected void validateRuntimeWithinLimits(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

    • getMaxCommandDuration

      protected Duration getMaxCommandDuration(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

    • getMaxCommandDuration

      protected Duration getMaxCommandDuration(String tenantId, PlatformEngineConfiguration platformEngineConfiguration)