public class BpelEngineImpl extends java.lang.Object implements BpelEngine
BpelEngine interface: provides the server methods that should be invoked in the context of a
transaction.| Modifier and Type | Field and Description |
|---|---|
java.util.HashMap<javax.xml.namespace.QName,BpelProcess> |
_activeProcesses
Active processes, keyed by process id.
|
| Constructor and Description |
|---|
BpelEngineImpl(Contexts contexts) |
| 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)
Create a "my role" message exchange for invoking a BPEL process.
|
MyRoleMessageExchange |
createMessageExchange(java.lang.String clientKey,
javax.xml.namespace.QName targetService,
java.lang.String operation,
java.lang.String pipedMexId) |
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)
Retrieve a message identified by the given identifer.
|
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)
Implements execution of the job.
|
void |
registerMessageExchangeInterceptor(MessageExchangeInterceptor interceptor) |
void |
sendMyRoleFault(BpelProcess process,
Scheduler.JobDetails we,
int causeCode) |
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) |
public final java.util.HashMap<javax.xml.namespace.QName,BpelProcess> _activeProcesses
public BpelEngineImpl(Contexts contexts)
public SharedEndpoints getSharedEndpoints()
public MyRoleMessageExchange createMessageExchange(java.lang.String clientKey, javax.xml.namespace.QName targetService, java.lang.String operation, java.lang.String pipedMexId) throws BpelEngineException
BpelEngineExceptionpublic MyRoleMessageExchange createMessageExchange(java.lang.String clientKey, javax.xml.namespace.QName targetService, java.lang.String operation)
BpelEnginecreateMessageExchange in interface BpelEnginetargetService - the service id of the process being called, if knownoperation - name of the operationMyRoleMessageExchange the newly created message exchangepublic MessageExchange getMessageExchange(java.lang.String mexId)
BpelEnginegetMessageExchange in interface BpelEnginemexId - message exhcange identifierprotected PartnerRoleMessageExchangeImpl createPartnerRoleMessageExchangeImpl(MessageExchangeDAO mexdao, javax.wsdl.PortType ptype, javax.wsdl.Operation op, OPartnerLink plink, BpelProcess process)
public BpelProcess getProcess(javax.xml.namespace.QName pid)
public void acquireInstanceLock(java.lang.Long iid)
public void onScheduledJob(Scheduler.JobInfo jobInfo) throws Scheduler.JobProcessorException
Scheduler.JobProcessoronScheduledJob in interface Scheduler.JobProcessorjobInfo - the job informationScheduler.JobProcessorExceptionpublic void registerMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
public void unregisterMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
public void unregisterMessageExchangeInterceptor(java.lang.Class interceptorClass)
public long getTotalBpelFootprint()
public long getHydratedFootprint()
public long getHydratedProcessSize(javax.xml.namespace.QName processName)
getHydratedProcessSize in interface BpelEnginepublic int getHydratedProcessCount(javax.xml.namespace.QName processName)
getHydratedProcessCount in interface BpelEnginepublic void setInstanceThrottledMaximumCount(int instanceThrottledMaximumCount)
public int getInstanceThrottledMaximumCount()
public void setProcessThrottledMaximumCount(int hydrationThrottledMaximumCount)
public int getProcessThrottledMaximumCount()
getProcessThrottledMaximumCount in interface BpelEnginepublic void setProcessThrottledMaximumSize(long hydrationThrottledMaximumSize)
public long getProcessThrottledMaximumSize()
getProcessThrottledMaximumSize in interface BpelEnginepublic void setProcessSize(javax.xml.namespace.QName processId,
boolean hydratedOnce)
public boolean dehydrateLastUnusedProcess()
dehydrateLastUnusedProcess in interface BpelEnginepublic void sendMyRoleFault(BpelProcess process, Scheduler.JobDetails we, int causeCode)
public BpelProcess getNewestProcessByType(javax.xml.namespace.QName processType)