| Package | Description |
|---|---|
| org.apache.ode.bpel.engine | |
| org.apache.ode.bpel.engine.migration | |
| org.apache.ode.bpel.engine.replayer | |
| org.apache.ode.bpel.intercept |
| Modifier and Type | Field and Description |
|---|---|
protected BpelProcess |
BpelRuntimeContextImpl._bpelProcess |
protected BpelProcess |
MyRoleMessageExchangeImpl._process |
| Modifier and Type | Field and Description |
|---|---|
java.util.HashMap<javax.xml.namespace.QName,BpelProcess> |
BpelEngineImpl._activeProcesses
Active processes, keyed by process id.
|
| Modifier and Type | Method and Description |
|---|---|
protected BpelProcess |
BpelServerImpl.createBpelProcess(ProcessConf conf) |
protected BpelProcess |
BpelRuntimeContextImpl.getBpelProcess() |
BpelProcess |
InterceptorContextImpl.getBpelProcess() |
BpelProcess |
BpelEngineImpl.getNewestProcessByType(javax.xml.namespace.QName processType) |
BpelProcess |
BpelEngineImpl.getProcess(javax.xml.namespace.QName pid) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<BpelProcess> |
DehydrationPolicy.markForDehydration(java.util.List<BpelProcess> runningProcesses)
Checks the currently running processes and marks some of them for
dehydration according to a specifically configured policy.
|
java.util.List<BpelProcess> |
CountLRUDehydrationPolicy.markForDehydration(java.util.List<BpelProcess> runningProcesses) |
| Modifier and Type | Method and Description |
|---|---|
protected PartnerRoleMessageExchangeImpl |
BpelEngineImpl.createPartnerRoleMessageExchangeImpl(MessageExchangeDAO mexdao,
javax.wsdl.PortType ptype,
javax.wsdl.Operation op,
OPartnerLink plink,
BpelProcess process) |
void |
ProcessLifecycleCallback.hydrated(BpelProcess process) |
void |
BpelEngineImpl.sendMyRoleFault(BpelProcess process,
Scheduler.JobDetails we,
int causeCode) |
void |
BpelEngineImpl.sendMyRoleFault(BpelProcess process,
Scheduler.JobDetails we,
InvalidProcessException ipe) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<BpelProcess> |
DehydrationPolicy.markForDehydration(java.util.List<BpelProcess> runningProcesses)
Checks the currently running processes and marks some of them for
dehydration according to a specifically configured policy.
|
java.util.List<BpelProcess> |
CountLRUDehydrationPolicy.markForDehydration(java.util.List<BpelProcess> runningProcesses) |
| Constructor and Description |
|---|
BpelRuntimeContextImpl(BpelProcess bpelProcess,
ProcessInstanceDAO dao,
PROCESS PROCESS,
MyRoleMessageExchangeImpl instantiatingMessageExchange) |
BrokeredMyRoleMessageExchangeImpl(BpelProcess process,
BpelEngineImpl engine,
java.util.List<MyRoleMessageExchange> subscribers,
MessageExchangeDAO mexDao,
MyRoleMessageExchange template)
Creates a new BrokeredReliableMyRoleMessageExchangeImpl object.
|
DebuggerSupport(BpelProcess process)
Constructor.
|
InterceptorContextImpl(BpelDAOConnection connection,
ProcessDAO processDAO,
ProcessConf pconf,
BpelEngine bpelEngine,
BpelProcess bpelProcess) |
MyRoleMessageExchangeImpl(BpelProcess process,
BpelEngineImpl engine,
MessageExchangeDAO mexdao) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
Migration.migrate(java.util.Set<BpelProcess> registeredProcesses,
BpelDAOConnection connection)
All database migrations are run in the same transaction so if one fails, they will
all be rollbacked.
|
boolean |
CorrelatorsMigration.migrate(java.util.Set<BpelProcess> registeredProcesses,
BpelDAOConnection connection) |
boolean |
OutstandingRequestsMigration.migrate(java.util.Set<BpelProcess> registeredProcesses,
BpelDAOConnection connection) |
boolean |
CorrelationKeyMigration.migrate(java.util.Set<BpelProcess> registeredProcesses,
BpelDAOConnection connection) |
boolean |
CorrelationKeySetMigration.migrate(java.util.Set<BpelProcess> registeredProcesses,
BpelDAOConnection connection) |
boolean |
CorrelationKeySetDataMigration.migrate(java.util.Set<BpelProcess> registeredProcesses,
BpelDAOConnection connection) |
boolean |
MigrationHandler.migrate(java.util.Set<BpelProcess> registeredProcesses,
int migrationTransactionTimeout) |
| Constructor and Description |
|---|
ReplayerBpelRuntimeContextImpl(BpelProcess bpelProcess,
ProcessInstanceDAO dao,
PROCESS PROCESS,
MyRoleMessageExchangeImpl instantiatingMessageExchange,
ReplayerContext context) |
| Modifier and Type | Method and Description |
|---|---|
BpelProcess |
MessageExchangeInterceptor.InterceptorContext.getBpelProcess() |
Copyright © 2021 WSO2. All Rights Reserved.