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

Class JcaExecutorServiceConnector

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

The ResourceAdapter responsible for bootstrapping the JcaExecutorService

Author:
Daniel Meyer
See Also:

  • Field Details

    • ORG_CAMUNDA_BPM_ENGINE_PROCESS_ENGINE

      public static final String ORG_CAMUNDA_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/camunda-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(javax.resource.spi.BootstrapContext ctx) throws javax.resource.spi.ResourceAdapterInternalException
      Specified by:
      start in interface javax.resource.spi.ResourceAdapter
      Throws:
      javax.resource.spi.ResourceAdapterInternalException

    • stop

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

    • endpointActivation

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

    • endpointDeactivation

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

    • getXAResources

      public XAResource[] getXAResources(javax.resource.spi.ActivationSpec[] specs) throws javax.resource.ResourceException
      Specified by:
      getXAResources in interface javax.resource.spi.ResourceAdapter
      Throws:
      javax.resource.ResourceException

    • 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