|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.ode.bpel.rtrep.v2.RuntimeInstanceImpl
public class RuntimeInstanceImpl
Implementation of OdeInternalInstance
for the "modern" runtime. This class also serves as a repository for kitchen sink type
methods that the activities all use. A lot of these methods are simply deferals to similar methods on
OdeRTInstanceContext
; however here these methods use representation-specific classes (e.g.
OPartnerLink) while the {@link OdeRTInstanceContext} methods use only the general (non-representation specific) interfaces
(e.g. {@link PartnerLink}.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.apache.ode.bpel.rapi.OdeRTInstance |
---|
OdeRTInstance.InvokeResponseType |
Field Summary | |
---|---|
protected ExecutionQueueImpl |
_soup
JACOB ExecutionQueue (state) |
protected JacobVPU |
_vpu
JACOB VPU |
Constructor Summary | |
---|---|
RuntimeInstanceImpl(RuntimeImpl runtime,
ExecutionQueueImpl soup)
|
Method Summary | |
---|---|
void |
cancel(PickResponseChannel responseChannel)
Proxy to BpelRuntimeContext# . |
void |
cancelOutstandingRequests(java.lang.String channelId)
|
void |
commitChanges(VariableInstance var,
org.apache.ode.bpel.rtrep.v2.ScopeFrame scopeFrame,
org.w3c.dom.Node value)
|
void |
completedFault(FaultData faultData)
|
void |
completedOk()
|
org.w3c.dom.Node |
convertEndpointReference(org.w3c.dom.Element epr,
org.w3c.dom.Node lvaluePtr)
Proxy to VariableContext.convertEndpointReference(Element, Node) . |
ExtensionOperation |
createExtensionActivityImplementation(javax.xml.namespace.QName name)
|
java.lang.Long |
createScopeInstance(java.lang.Long scopeInstanceId,
OScope scopedef)
Proxy to VariableContext.createScopeInstance(Long, String, int) . |
java.lang.Long |
createScopeInstance(java.lang.Long parentScopeId,
java.lang.String name,
int modelId)
|
boolean |
execute()
|
org.w3c.dom.Node |
fetchMyRoleEndpointReferenceData(PartnerLinkInstance link)
Proxy to VariableContext.fetchMyRoleEndpointReferenceData(PartnerLink) . |
java.lang.String |
fetchMySessionId(PartnerLinkInstance linkInstance)
Proxy to BpelRuntimeContext# . |
org.w3c.dom.Node |
fetchPartnerRoleEndpointReferenceData(PartnerLinkInstance link)
|
org.w3c.dom.Node |
fetchVariableData(VariableInstance variable,
org.apache.ode.bpel.rtrep.v2.ScopeFrame scopeFrame,
boolean forWriting)
|
org.w3c.dom.Node |
fetchVariableData(VariableInstance var,
org.apache.ode.bpel.rtrep.v2.ScopeFrame scopeFrame,
OMessageVarType.Part part,
boolean forWriting)
|
void |
forceFlush()
Proxy to ProcessControlContext.forceFlush() . |
void |
forceRollback()
Proxy to ProcessControlContext.forceRollback() . |
long |
genId()
Proxy to OdeRTInstanceContext.genId() . |
java.net.URI |
getBaseResourceURI()
|
ExpressionLanguageRuntimeRegistry |
getExpLangRuntime()
|
org.w3c.dom.Element |
getMyRequest(java.lang.String mexId)
Proxy to BpelRuntimeContext# . |
org.w3c.dom.Node |
getPartData(org.w3c.dom.Element message,
OMessageVarType.Part part)
|
javax.xml.namespace.QName |
getPartnerFault(java.lang.String mexId)
Proxy to IOContext.getPartnerFault(String) . |
java.lang.String |
getPartnerFaultExplanation(java.lang.String mexId)
Proxy to IOContext.getPartnerFaultExplanation(String) . |
org.w3c.dom.Element |
getPartnerResponse(java.lang.String mexId)
Proxy to IOContext.getPartnerResponse(String) . |
javax.xml.namespace.QName |
getPartnerResponseType(java.lang.String mexId)
Proxy to IOContext.getPartnerResponseType(String) . |
java.lang.Long |
getPid()
Proxy to ProcessControlContext# . |
ProcessModel |
getProcessModel()
|
org.w3c.dom.Node |
getProcessProperty(javax.xml.namespace.QName propertyName)
Retrieves the property value that has been defined for this BPEL Process type. |
int |
getRetryDelay()
|
org.w3c.dom.Node |
getSourceEPR(java.lang.String mexId)
|
java.lang.String |
getSourceSessionId(java.lang.String mexId)
Proxy to IOContext.getSourceSessionId(String) . |
void |
initializePartnerLinks(java.lang.Long parentScopeId,
java.util.Collection<OPartnerLink> partnerLinks)
|
void |
initializePartnersSessionId(PartnerLinkInstance instance,
java.lang.String partnersSessionId)
Proxy to BpelRuntimeContext# . |
org.w3c.dom.Node |
initializeVariable(VariableInstance var,
org.apache.ode.bpel.rtrep.v2.ScopeFrame scopeFrame,
org.w3c.dom.Node val)
Proxy to VariableContext.initializeVariable(Variable, Node) then write properties. |
java.lang.String |
invoke(java.lang.String invokeId,
PartnerLinkInstance instance,
javax.wsdl.Operation operation,
org.w3c.dom.Element outboundMsg,
java.lang.Object object)
|
boolean |
isCorrelationInitialized(CorrelationSetInstance correlationSet)
|
boolean |
isFirstTry()
|
boolean |
isPartnerRoleEndpointInitialized(PartnerLinkInstance pLink)
|
boolean |
isRetryable()
|
boolean |
isVariableInitialized(VariableInstance var)
|
void |
onCreateInstance(java.lang.String messageExchangeId)
Called when the engine creates an instance (i.e. |
void |
onInvokeResponse(java.lang.String invokeId,
OdeRTInstance.InvokeResponseType irt,
java.lang.String mexid)
Called when an invoke received a response. |
void |
onSelectEvent(java.lang.String selectId,
java.lang.String messageExchangeId,
int selectorIdx)
Called when the engine detects a matching selector (i.e. |
void |
onTimerEvent(java.lang.String timerId)
Called when the engine determines that a registered timer is ready to fire. |
CorrelationKey |
readCorrelation(CorrelationSetInstance cset)
|
java.lang.String |
readProperty(VariableInstance variable,
OProcess.OProperty property)
Proxy to VariableContext.readVariableProperty(Variable, QName) . |
void |
recoverActivity(java.lang.String channel,
long activityId,
java.lang.String action,
FaultInfo fault)
|
void |
registerActivityForRecovery(ActivityRecoveryChannel recoveryChannel,
long id,
java.lang.String reason,
java.util.Date dateTime,
org.w3c.dom.Element details,
java.lang.String[] actions,
int retryCount)
Proxy to RecoveryContext.registerActivityForRecovery(String, long, String, Date, Element, String[], int) . |
void |
registerTimer(TimerResponseChannel timerChannel,
java.util.Date future)
Proxy to IOContext.registerTimer(String, Date) . |
void |
releasePartnerMex(java.lang.String mexId,
boolean instanceSucceeded)
Proxy to IOContext#releasePartnerMex(String) . |
void |
reply(PartnerLinkInstance plink,
java.lang.String opName,
java.lang.String bpelmex,
org.w3c.dom.Element element,
javax.xml.namespace.QName fault)
Proxy to IOContext#reply(PartnerLink, String, String, Element, QName) . |
java.lang.Object |
saveState(java.io.OutputStream bos)
Save the execution state into the given output stream, and return a cached representation of the state. |
void |
select(PickResponseChannel pickResponseChannel,
java.util.Date timeout,
boolean createInstance,
Selector[] selectors)
|
void |
sendEvent(ProcessInstanceStartedEvent evt)
Proxy to OdeRTInstanceContext.sendEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent) . |
void |
sendEvent(ScopeEvent event)
Proxy to OdeRTInstanceContext.sendEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent) . |
void |
setAtomicScope(boolean atomicScope)
|
void |
setContext(OdeRTInstanceContext ctx)
Set the execution context. |
void |
setRetriedOnce()
|
void |
setRetriesDone()
|
void |
terminate()
Proxy to ProcessControlContext.terminate() . |
void |
unregisterActivityForRecovery(ActivityRecoveryChannel recoveryChannel)
|
void |
writeCorrelation(CorrelationSetInstance cset,
CorrelationKey ckeyVal)
|
void |
writeEndpointReference(PartnerLinkInstance plval,
org.w3c.dom.Element element)
Proxy to BpelRuntimeContext# . |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected JacobVPU _vpu
protected ExecutionQueueImpl _soup
Constructor Detail |
---|
public RuntimeInstanceImpl(RuntimeImpl runtime, ExecutionQueueImpl soup)
Method Detail |
---|
public ProcessModel getProcessModel()
public boolean isCorrelationInitialized(CorrelationSetInstance correlationSet)
isCorrelationInitialized
in interface OdeInternalInstance
public boolean isVariableInitialized(VariableInstance var)
isVariableInitialized
in interface OdeInternalInstance
public boolean isPartnerRoleEndpointInitialized(PartnerLinkInstance pLink)
isPartnerRoleEndpointInitialized
in interface OdeInternalInstance
public void completedFault(FaultData faultData)
completedFault
in interface OdeInternalInstance
public void completedOk()
completedOk
in interface OdeInternalInstance
public java.lang.Long createScopeInstance(java.lang.Long parentScopeId, java.lang.String name, int modelId)
public void initializePartnerLinks(java.lang.Long parentScopeId, java.util.Collection<OPartnerLink> partnerLinks)
initializePartnerLinks
in interface OdeInternalInstance
public void cancelOutstandingRequests(java.lang.String channelId)
cancelOutstandingRequests
in interface OdeInternalInstance
public void select(PickResponseChannel pickResponseChannel, java.util.Date timeout, boolean createInstance, Selector[] selectors) throws FaultException
select
in interface OdeInternalInstance
FaultException
public CorrelationKey readCorrelation(CorrelationSetInstance cset)
readCorrelation
in interface OdeInternalInstance
public org.w3c.dom.Node fetchVariableData(VariableInstance variable, org.apache.ode.bpel.rtrep.v2.ScopeFrame scopeFrame, boolean forWriting) throws FaultException
fetchVariableData
in interface OdeInternalInstance
FaultException
public org.w3c.dom.Node fetchVariableData(VariableInstance var, org.apache.ode.bpel.rtrep.v2.ScopeFrame scopeFrame, OMessageVarType.Part part, boolean forWriting) throws FaultException
fetchVariableData
in interface OdeInternalInstance
FaultException
public void writeCorrelation(CorrelationSetInstance cset, CorrelationKey ckeyVal) throws FaultException
writeCorrelation
in interface OdeInternalInstance
FaultException
public void sendEvent(ScopeEvent event)
OdeRTInstanceContext.sendEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent)
.
sendEvent
in interface OdeInternalInstance
event
- public void unregisterActivityForRecovery(ActivityRecoveryChannel recoveryChannel)
unregisterActivityForRecovery
in interface OdeInternalInstance
public void registerActivityForRecovery(ActivityRecoveryChannel recoveryChannel, long id, java.lang.String reason, java.util.Date dateTime, org.w3c.dom.Element details, java.lang.String[] actions, int retryCount)
RecoveryContext.registerActivityForRecovery(String, long, String, Date, Element, String[], int)
.
registerActivityForRecovery
in interface OdeInternalInstance
public void registerTimer(TimerResponseChannel timerChannel, java.util.Date future)
IOContext.registerTimer(String, Date)
.
registerTimer
in interface OdeInternalInstance
public java.lang.String readProperty(VariableInstance variable, OProcess.OProperty property) throws FaultException
VariableContext.readVariableProperty(Variable, QName)
.
readProperty
in interface OdeInternalInstance
FaultException
public long genId()
OdeRTInstanceContext.genId()
.
genId
in interface OdeInternalInstance
public org.w3c.dom.Node initializeVariable(VariableInstance var, org.apache.ode.bpel.rtrep.v2.ScopeFrame scopeFrame, org.w3c.dom.Node val) throws ExternalVariableModuleException
VariableContext.initializeVariable(Variable, Node)
then write properties.
initializeVariable
in interface OdeInternalInstance
ExternalVariableModuleException
public org.w3c.dom.Node fetchMyRoleEndpointReferenceData(PartnerLinkInstance link)
VariableContext.fetchMyRoleEndpointReferenceData(PartnerLink)
.
fetchMyRoleEndpointReferenceData
in interface OdeInternalInstance
public org.w3c.dom.Node fetchPartnerRoleEndpointReferenceData(PartnerLinkInstance link) throws FaultException
fetchPartnerRoleEndpointReferenceData
in interface OdeInternalInstance
FaultException
public org.w3c.dom.Node convertEndpointReference(org.w3c.dom.Element epr, org.w3c.dom.Node lvaluePtr)
VariableContext.convertEndpointReference(Element, Node)
.
convertEndpointReference
in interface OdeInternalInstance
public void commitChanges(VariableInstance var, org.apache.ode.bpel.rtrep.v2.ScopeFrame scopeFrame, org.w3c.dom.Node value) throws ExternalVariableModuleException
commitChanges
in interface OdeInternalInstance
ExternalVariableModuleException
public void writeEndpointReference(PartnerLinkInstance plval, org.w3c.dom.Element element)
BpelRuntimeContext#
.
writeEndpointReference
in interface OdeInternalInstance
public java.lang.Long createScopeInstance(java.lang.Long scopeInstanceId, OScope scopedef)
VariableContext.createScopeInstance(Long, String, int)
.
createScopeInstance
in interface OdeInternalInstance
public java.lang.String fetchMySessionId(PartnerLinkInstance linkInstance)
BpelRuntimeContext#
.
fetchMySessionId
in interface OdeInternalInstance
public void cancel(PickResponseChannel responseChannel)
BpelRuntimeContext#
.
cancel
in interface OdeInternalInstance
public org.w3c.dom.Element getMyRequest(java.lang.String mexId)
BpelRuntimeContext#
.
getMyRequest
in interface OdeInternalInstance
public void initializePartnersSessionId(PartnerLinkInstance instance, java.lang.String partnersSessionId)
BpelRuntimeContext#
.
initializePartnersSessionId
in interface OdeInternalInstance
public java.lang.String getSourceSessionId(java.lang.String mexId)
IOContext.getSourceSessionId(String)
.
getSourceSessionId
in interface OdeInternalInstance
public org.w3c.dom.Node getSourceEPR(java.lang.String mexId)
getSourceEPR
in interface OdeInternalInstance
public ExtensionOperation createExtensionActivityImplementation(javax.xml.namespace.QName name)
createExtensionActivityImplementation
in interface OdeInternalInstance
public java.lang.Long getPid()
ProcessControlContext#
.
getPid
in interface OdeInternalInstance
public org.w3c.dom.Element getPartnerResponse(java.lang.String mexId)
IOContext.getPartnerResponse(String)
.
getPartnerResponse
in interface OdeInternalInstance
public void releasePartnerMex(java.lang.String mexId, boolean instanceSucceeded)
IOContext#releasePartnerMex(String)
.
releasePartnerMex
in interface OdeInternalInstance
public javax.xml.namespace.QName getPartnerFault(java.lang.String mexId)
IOContext.getPartnerFault(String)
.
getPartnerFault
in interface OdeInternalInstance
public javax.xml.namespace.QName getPartnerResponseType(java.lang.String mexId)
IOContext.getPartnerResponseType(String)
.
getPartnerResponseType
in interface OdeInternalInstance
public java.lang.String getPartnerFaultExplanation(java.lang.String mexId)
IOContext.getPartnerFaultExplanation(String)
.
getPartnerFaultExplanation
in interface OdeInternalInstance
public void sendEvent(ProcessInstanceStartedEvent evt)
OdeRTInstanceContext.sendEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent)
.
sendEvent
in interface OdeInternalInstance
public void reply(PartnerLinkInstance plink, java.lang.String opName, java.lang.String bpelmex, org.w3c.dom.Element element, javax.xml.namespace.QName fault) throws FaultException
IOContext#reply(PartnerLink, String, String, Element, QName)
.
reply
in interface OdeInternalInstance
FaultException
public void forceFlush()
ProcessControlContext.forceFlush()
.
forceFlush
in interface OdeInternalInstance
public void forceRollback()
ProcessControlContext.forceRollback()
.
forceRollback
in interface OdeInternalInstance
public void terminate()
ProcessControlContext.terminate()
.
terminate
in interface OdeInternalInstance
public org.w3c.dom.Node getPartData(org.w3c.dom.Element message, OMessageVarType.Part part)
getPartData
in interface OdeInternalInstance
public java.lang.String invoke(java.lang.String invokeId, PartnerLinkInstance instance, javax.wsdl.Operation operation, org.w3c.dom.Element outboundMsg, java.lang.Object object) throws FaultException
invoke
in interface OdeInternalInstance
instance
- operation
- outboundMsg
- object
-
FaultException
public ExpressionLanguageRuntimeRegistry getExpLangRuntime()
getExpLangRuntime
in interface OdeInternalInstance
public void onSelectEvent(java.lang.String selectId, java.lang.String messageExchangeId, int selectorIdx)
OdeRTInstance
onSelectEvent
in interface OdeRTInstance
selectId
- selector identifiermessageExchangeId
- message exchange identifierselectorIdx
- which selector in the set matchedpublic void onTimerEvent(java.lang.String timerId)
OdeRTInstance
onTimerEvent
in interface OdeRTInstance
public boolean execute()
execute
in interface OdeRTInstance
public void onInvokeResponse(java.lang.String invokeId, OdeRTInstance.InvokeResponseType irt, java.lang.String mexid)
OdeRTInstance
onInvokeResponse
in interface OdeRTInstance
public void recoverActivity(java.lang.String channel, long activityId, java.lang.String action, FaultInfo fault)
recoverActivity
in interface OdeRTInstance
public java.lang.Object saveState(java.io.OutputStream bos) throws java.io.IOException
OdeRTInstance
saveState
in interface OdeRTInstance
java.io.IOException
public void onCreateInstance(java.lang.String messageExchangeId)
OdeRTInstance
onCreateInstance
in interface OdeRTInstance
messageExchangeId
- message exchange id for create-instance mexpublic void setContext(OdeRTInstanceContext ctx)
OdeRTInstance
setContext
in interface OdeRTInstance
public java.net.URI getBaseResourceURI()
getBaseResourceURI
in interface OdeInternalInstance
public int getRetryDelay()
getRetryDelay
in interface OdeInternalInstance
public boolean isFirstTry()
isFirstTry
in interface OdeInternalInstance
public boolean isRetryable()
isRetryable
in interface OdeInternalInstance
public void setRetriedOnce()
setRetriedOnce
in interface OdeInternalInstance
public void setRetriesDone()
setRetriesDone
in interface OdeInternalInstance
public void setAtomicScope(boolean atomicScope)
setAtomicScope
in interface OdeInternalInstance
public org.w3c.dom.Node getProcessProperty(javax.xml.namespace.QName propertyName)
OdeInternalInstance
getProcessProperty
in interface OdeInternalInstance
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |