|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.ode.bpel.engine.BpelEngineImpl
public class BpelEngineImpl
Implementation of the BpelEngine
interface: provides the server methods that should be invoked in the context of a
transaction.
Constructor Summary | |
---|---|
BpelEngineImpl(Contexts contexts)
|
Method Summary | |
---|---|
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 |
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,
WorkEvent 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)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public BpelEngineImpl(Contexts contexts)
Method Detail |
---|
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 operation
MyRoleMessageExchange
the newly created message exchangepublic MessageExchange getMessageExchange(java.lang.String mexId)
BpelEngine
getMessageExchange
in interface BpelEngine
mexId
- message exhcange identifier
protected 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 onScheduledJob(Scheduler.JobInfo jobInfo) throws Scheduler.JobProcessorException
Scheduler.JobProcessor
onScheduledJob
in interface Scheduler.JobProcessor
jobInfo
- the job information
Scheduler.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, WorkEvent we, int causeCode)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |