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

Class JcaExecutorServiceConnector

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, javax.resource.spi.ResourceAdapter

@Connector(reauthenticationSupport=false,
           transactionSupport=NoTransaction)
public class JcaExecutorServiceConnector
extends java.lang.Object
implements javax.resource.spi.ResourceAdapter, java.io.Serializable

The ResourceAdapter responsible for bootstrapping the JcaExecutorService

Author:

Daniel Meyer

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
protected java.lang.String	commonJWorkManagerName
protected JcaExecutorServiceConnector.ExecutorServiceWrapper	executorServiceWrapper
protected java.lang.Boolean	isUseCommonJWorkManager
protected JobExecutionHandlerActivation	jobHandlerActivation
static java.lang.String	ORG_CAMUNDA_BPM_ENGINE_PROCESS_ENGINE

Constructor Summary

Constructors

Constructor	Description
JcaExecutorServiceConnector()

Method Summary

Modifier and Type	Method	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(java.lang.Object other)
java.lang.String	getCommonJWorkManagerName()
JcaExecutorServiceConnector.ExecutorServiceWrapper	getExecutorServiceWrapper()
java.lang.Boolean	getIsUseCommonJWorkManager()
JobExecutionHandlerActivation	getJobHandlerActivation()
javax.transaction.xa.XAResource[]	getXAResources(javax.resource.spi.ActivationSpec[] specs)
int	hashCode()
void	setCommonJWorkManagerName(java.lang.String commonJWorkManagerName)
void	setIsUseCommonJWorkManager(java.lang.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 java.lang.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 java.lang.Boolean isUseCommonJWorkManager

commonJWorkManagerName

@ConfigProperty(type=java.lang.String.class,
                defaultValue="wm/camunda-bpm-workmanager",
                description="Allows specifying the name of a CommonJ Workmanager.")
protected java.lang.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 javax.transaction.xa.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 java.lang.Boolean getIsUseCommonJWorkManager()

setIsUseCommonJWorkManager

public void setIsUseCommonJWorkManager(java.lang.Boolean isUseCommonJWorkManager)

getCommonJWorkManagerName

public java.lang.String getCommonJWorkManagerName()

setCommonJWorkManagerName

public void setCommonJWorkManagerName(java.lang.String commonJWorkManagerName)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object other)

Overrides:

equals in class java.lang.Object