org.apache.ode.bpel.engine

Class BpelEngineImpl

java.lang.Object

org.apache.ode.bpel.engine.BpelEngineImpl

All Implemented Interfaces:

BpelEngine, Scheduler.JobProcessor

public class BpelEngineImpl
extends java.lang.Object
implements BpelEngine

Implementation of the BpelEngine interface: provides the server methods that should be invoked in the context of a transaction.

Author:

mszefler, Matthieu Riou

Field Summary

Fields

Modifier and Type	Field and Description
java.util.HashMap<javax.xml.namespace.QName,BpelProcess>	_activeProcesses Active processes, keyed by process id.

Constructor Summary

Constructors

Constructor and Description
BpelEngineImpl(Contexts contexts)

Method Summary

Modifier and Type	Method and Description
void	acquireInstanceLock(java.lang.Long iid)
MyRoleMessageExchange	createMessageExchange(java.lang.String clientKey, javax.xml.namespace.QName targetService, java.lang.String operation)
MyRoleMessageExchange	createMessageExchange(java.lang.String clientKey, javax.xml.namespace.QName targetService, java.lang.String operation, java.lang.String pipedMexId)
MyRoleMessageExchange	createMessageExchange(java.lang.String clientKey, javax.xml.namespace.QName targetService, java.lang.String operation, java.lang.String pipedMexId, java.lang.String deployer)
protected PartnerRoleMessageExchangeImpl	createPartnerRoleMessageExchangeImpl(MessageExchangeDAO mexdao, javax.wsdl.PortType ptype, javax.wsdl.Operation op, OPartnerLink plink, BpelProcess process)
boolean	dehydrateLastUnusedProcess() Returns true if the last used process was dehydrated because it was not in-use.
long	getHydratedFootprint()
int	getHydratedProcessCount(javax.xml.namespace.QName processName)
long	getHydratedProcessSize(javax.xml.namespace.QName processName)
int	getInstanceThrottledMaximumCount()
MessageExchange	getMessageExchange(java.lang.String mexId)
BpelProcess	getNewestProcessByType(javax.xml.namespace.QName processType)
BpelProcess	getProcess(javax.xml.namespace.QName pid)
int	getProcessThrottledMaximumCount()
long	getProcessThrottledMaximumSize()
SharedEndpoints	getSharedEndpoints()
long	getTotalBpelFootprint()
void	onScheduledJob(Scheduler.JobInfo jobInfo)
void	registerMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
void	sendMyRoleFault(BpelProcess process, Scheduler.JobDetails we, int causeCode)
void	sendMyRoleFault(BpelProcess process, Scheduler.JobDetails we, InvalidProcessException ipe)
void	setHazelcastInstance(com.hazelcast.core.HazelcastInstance instance)
void	setInstanceThrottledMaximumCount(int instanceThrottledMaximumCount)
void	setProcessSize(javax.xml.namespace.QName processId, boolean hydratedOnce)
void	setProcessThrottledMaximumCount(int hydrationThrottledMaximumCount)
void	setProcessThrottledMaximumSize(long hydrationThrottledMaximumSize)
void	unregisterMessageExchangeInterceptor(java.lang.Class interceptorClass)
void	unregisterMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)

Methods inherited from class java.lang.Object

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

Field Detail

_activeProcesses

public final java.util.HashMap<javax.xml.namespace.QName,BpelProcess> _activeProcesses

Active processes, keyed by process id.

Constructor Detail

BpelEngineImpl

public BpelEngineImpl(Contexts contexts)

Method Detail

setHazelcastInstance

public void setHazelcastInstance(com.hazelcast.core.HazelcastInstance instance)

getSharedEndpoints

public SharedEndpoints getSharedEndpoints()

createMessageExchange

public MyRoleMessageExchange createMessageExchange(java.lang.String clientKey,
                                                   javax.xml.namespace.QName targetService,
                                                   java.lang.String operation,
                                                   java.lang.String pipedMexId,
                                                   java.lang.String deployer)
                                            throws BpelEngineException

Specified by:

createMessageExchange in interface BpelEngine

Throws:

BpelEngineException

createMessageExchange

public MyRoleMessageExchange createMessageExchange(java.lang.String clientKey,
                                                   javax.xml.namespace.QName targetService,
                                                   java.lang.String operation,
                                                   java.lang.String pipedMexId)
                                            throws BpelEngineException

Throws:

BpelEngineException

createMessageExchange

public MyRoleMessageExchange createMessageExchange(java.lang.String clientKey,
                                                   javax.xml.namespace.QName targetService,
                                                   java.lang.String operation)

Specified by:

createMessageExchange in interface BpelEngine

getMessageExchange

public MessageExchange getMessageExchange(java.lang.String mexId)

Specified by:

getMessageExchange in interface BpelEngine

createPartnerRoleMessageExchangeImpl

protected PartnerRoleMessageExchangeImpl createPartnerRoleMessageExchangeImpl(MessageExchangeDAO mexdao,
                                                                              javax.wsdl.PortType ptype,
                                                                              javax.wsdl.Operation op,
                                                                              OPartnerLink plink,
                                                                              BpelProcess process)

getProcess

public BpelProcess getProcess(javax.xml.namespace.QName pid)

acquireInstanceLock

public void acquireInstanceLock(java.lang.Long iid)

onScheduledJob

public void onScheduledJob(Scheduler.JobInfo jobInfo)
                    throws Scheduler.JobProcessorException

Specified by:

onScheduledJob in interface Scheduler.JobProcessor

Throws:

Scheduler.JobProcessorException

registerMessageExchangeInterceptor

public void registerMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)

unregisterMessageExchangeInterceptor

public void unregisterMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)

unregisterMessageExchangeInterceptor

public void unregisterMessageExchangeInterceptor(java.lang.Class interceptorClass)

getTotalBpelFootprint

public long getTotalBpelFootprint()

getHydratedFootprint

public long getHydratedFootprint()

getHydratedProcessSize

public long getHydratedProcessSize(javax.xml.namespace.QName processName)

Specified by:

getHydratedProcessSize in interface BpelEngine

getHydratedProcessCount

public int getHydratedProcessCount(javax.xml.namespace.QName processName)

Specified by:

getHydratedProcessCount in interface BpelEngine

setInstanceThrottledMaximumCount

public void setInstanceThrottledMaximumCount(int instanceThrottledMaximumCount)

getInstanceThrottledMaximumCount

public int getInstanceThrottledMaximumCount()

setProcessThrottledMaximumCount

public void setProcessThrottledMaximumCount(int hydrationThrottledMaximumCount)

getProcessThrottledMaximumCount

public int getProcessThrottledMaximumCount()

Specified by:

getProcessThrottledMaximumCount in interface BpelEngine

setProcessThrottledMaximumSize

public void setProcessThrottledMaximumSize(long hydrationThrottledMaximumSize)

getProcessThrottledMaximumSize

public long getProcessThrottledMaximumSize()

Specified by:

getProcessThrottledMaximumSize in interface BpelEngine

setProcessSize

public void setProcessSize(javax.xml.namespace.QName processId,
                           boolean hydratedOnce)

dehydrateLastUnusedProcess

public boolean dehydrateLastUnusedProcess()

Returns true if the last used process was dehydrated because it was not in-use.

Specified by:

dehydrateLastUnusedProcess in interface BpelEngine

sendMyRoleFault

public void sendMyRoleFault(BpelProcess process,
                            Scheduler.JobDetails we,
                            InvalidProcessException ipe)

sendMyRoleFault

public void sendMyRoleFault(BpelProcess process,
                            Scheduler.JobDetails we,
                            int causeCode)

getNewestProcessByType

public BpelProcess getNewestProcessByType(javax.xml.namespace.QName processType)