Package org.operaton.bpm.container.impl.threading.ra

Class JcaExecutorServiceConnector

java.lang.Object
org.operaton.bpm.container.impl.threading.ra.JcaExecutorServiceConnector
All Implemented Interfaces:
jakarta.resource.spi.ResourceAdapter
@Connector(reauthenticationSupport=false, transactionSupport=NoTransaction) public class JcaExecutorServiceConnector extends Object implements jakarta.resource.spi.ResourceAdapter

The ResourceAdapter responsible for bootstrapping the JcaExecutorService

Author:
Daniel Meyer

  • Field Details

    • ORG_OPERATON_BPM_ENGINE_PROCESS_ENGINE

      public static final String ORG_OPERATON_BPM_ENGINE_PROCESS_ENGINE
      See Also:

    • executorServiceWrapper

      protected JcaExecutorServiceConnector.ExecutorServiceWrapper executorServiceWrapper

    • jobHandlerActivation

      protected JobExecutionHandlerActivation jobHandlerActivation

    • isUseCommonJWorkManager

      @ConfigProperty(type=java.lang.Boolean.class, defaultValue="false", description="If set to \'true\', the CommonJ WorkManager is used instead of the Jca Work Manager.Can only be used on platforms where a CommonJ WorkManager is available (such as IBM & Oracle)") protected Boolean isUseCommonJWorkManager

    • commonJWorkManagerName

      @ConfigProperty(type=java.lang.String.class, defaultValue="wm/operaton-bpm-workmanager", description="Allows specifying the name of a CommonJ WorkManager.") protected String commonJWorkManagerName

  • Constructor Details

    • JcaExecutorServiceConnector

      public JcaExecutorServiceConnector()

  • Method Details

    • start

      public void start(jakarta.resource.spi.BootstrapContext ctx) throws jakarta.resource.spi.ResourceAdapterInternalException
      Specified by:
      start in interface jakarta.resource.spi.ResourceAdapter
      Throws:
      jakarta.resource.spi.ResourceAdapterInternalException

    • stop

      public void stop()
      Specified by:
      stop in interface jakarta.resource.spi.ResourceAdapter

    • endpointActivation

      public void endpointActivation(jakarta.resource.spi.endpoint.MessageEndpointFactory endpointFactory, jakarta.resource.spi.ActivationSpec spec) throws jakarta.resource.ResourceException
      Specified by:
      endpointActivation in interface jakarta.resource.spi.ResourceAdapter
      Throws:
      jakarta.resource.ResourceException

    • endpointDeactivation

      public void endpointDeactivation(jakarta.resource.spi.endpoint.MessageEndpointFactory endpointFactory, jakarta.resource.spi.ActivationSpec spec)
      Specified by:
      endpointDeactivation in interface jakarta.resource.spi.ResourceAdapter

    • getXAResources

      public XAResource[] getXAResources(jakarta.resource.spi.ActivationSpec[] specs)
      Specified by:
      getXAResources in interface jakarta.resource.spi.ResourceAdapter

    • getExecutorServiceWrapper

      public JcaExecutorServiceConnector.ExecutorServiceWrapper getExecutorServiceWrapper()

    • getJobHandlerActivation

      public JobExecutionHandlerActivation getJobHandlerActivation()

    • getIsUseCommonJWorkManager

      public Boolean getIsUseCommonJWorkManager()

    • setIsUseCommonJWorkManager

      public void setIsUseCommonJWorkManager(Boolean isUseCommonJWorkManager)

    • getCommonJWorkManagerName

      public String getCommonJWorkManagerName()

    • setCommonJWorkManagerName

      public void setCommonJWorkManagerName(String commonJWorkManagerName)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object other)
      Overrides:
      equals in class Object