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:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	JcaExecutorServiceConnector.ExecutorServiceWrapper This class must be free of engine classes to make it possible to install the resource adapter without shared libraries.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	commonJWorkManagerName
protected JcaExecutorServiceConnector.ExecutorServiceWrapper	executorServiceWrapper
protected Boolean	isUseCommonJWorkManager
protected JobExecutionHandlerActivation	jobHandlerActivation
static String	ORG_CAMUNDA_BPM_ENGINE_PROCESS_ENGINE

Constructor Summary

Constructors

Constructor and Description
JcaExecutorServiceConnector()

Method Summary

Methods

Modifier and Type	Method and Description
void	endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, javax.resource.spi.ActivationSpec spec)
void	endpointDeactivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, javax.resource.spi.ActivationSpec spec)
boolean	equals(Object other)
String	getCommonJWorkManagerName()
JcaExecutorServiceConnector.ExecutorServiceWrapper	getExecutorServiceWrapper()
Boolean	getIsUseCommonJWorkManager()
JobExecutionHandlerActivation	getJobHandlerActivation()
XAResource[]	getXAResources(javax.resource.spi.ActivationSpec[] specs)
int	hashCode()
void	setCommonJWorkManagerName(String commonJWorkManagerName)
void	setIsUseCommonJWorkManager(Boolean isUseCommonJWorkManager)
void	start(javax.resource.spi.BootstrapContext ctx)
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

ORG_CAMUNDA_BPM_ENGINE_PROCESS_ENGINE

public static final String ORG_CAMUNDA_BPM_ENGINE_PROCESS_ENGINE

See Also:

Constant Field Values

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 Detail

JcaExecutorServiceConnector

public JcaExecutorServiceConnector()

Method Detail

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