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
BpelEngineException
public MyRoleMessageExchange createMessageExchange(java.lang.String clientKey, javax.xml.namespace.QName targetService, java.lang.String operation)
BpelEngine
createMessageExchange
in interface BpelEngine
targetService
- 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)
BpelEngine
getMessageExchange
in interface BpelEngine
mexId
- 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.JobProcessor
onScheduledJob
in interface Scheduler.JobProcessor
jobInfo
- the job informationScheduler.JobProcessorException
public 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 BpelEngine
public int getHydratedProcessCount(javax.xml.namespace.QName processName)
getHydratedProcessCount
in interface BpelEngine
public void setInstanceThrottledMaximumCount(int instanceThrottledMaximumCount)
public int getInstanceThrottledMaximumCount()
public void setProcessThrottledMaximumCount(int hydrationThrottledMaximumCount)
public int getProcessThrottledMaximumCount()
getProcessThrottledMaximumCount
in interface BpelEngine
public void setProcessThrottledMaximumSize(long hydrationThrottledMaximumSize)
public long getProcessThrottledMaximumSize()
getProcessThrottledMaximumSize
in interface BpelEngine
public void setProcessSize(javax.xml.namespace.QName processId, boolean hydratedOnce)
public boolean dehydrateLastUnusedProcess()
dehydrateLastUnusedProcess
in interface BpelEngine
public void sendMyRoleFault(BpelProcess process, Scheduler.JobDetails we, int causeCode)
public BpelProcess getNewestProcessByType(javax.xml.namespace.QName processType)