public class ReplayerBpelRuntimeContextImpl extends BpelRuntimeContextImpl
| Modifier and Type | Class and Description |
|---|---|
static class |
ReplayerBpelRuntimeContextImpl.TimerResume |
BpelRuntimeContext.ValueReferencePair_bpelProcess, _dao, _imaManager, _outstandingRequests, _soup, _vpu| Constructor and Description |
|---|
ReplayerBpelRuntimeContextImpl(BpelProcess bpelProcess,
ProcessInstanceDAO dao,
PROCESS PROCESS,
MyRoleMessageExchangeImpl instantiatingMessageExchange,
ReplayerContext context) |
| Modifier and Type | Method and Description |
|---|---|
static void |
assign(MessageDAO m,
org.apache.xmlbeans.XmlObject o) |
void |
cancel(TimerResponseChannel timerResponseChannel)
Cancel a timer, or pick.
|
void |
checkInvokeExternalPermission() |
void |
completedFault(FaultData faultData)
Should be invoked by process template, signalling process completion
with fault.
|
static MyRoleMessageExchangeImpl |
createMyRoleMex(CommunicationType.Exchange e,
BpelEngineImpl engine) |
ProcessInstanceDAO |
getDAO() |
void |
handleIncomingRequest(MyRoleMessageExchangeImpl mex,
java.util.Date currentEventDateTime) |
java.lang.String |
invoke(int aid,
PartnerLinkInstance partnerLink,
javax.wsdl.Operation operation,
org.w3c.dom.Element outgoingMessage,
InvokeResponseChannel channel)
Called back when the process executes an invokation.
|
void |
registerActivityForRecovery(ActivityRecoveryChannel channel,
long activityId,
java.lang.String reason,
java.util.Date dateTime,
org.w3c.dom.Element details,
java.lang.String[] actions,
int retries) |
void |
registerTimer(TimerResponseChannel timerChannel,
java.util.Date timeToFire)
Registers a timer for future notification.
|
void |
reply(PartnerLinkInstance plinkInstnace,
java.lang.String opName,
java.lang.String mexId,
org.w3c.dom.Element msg,
javax.xml.namespace.QName fault)
Send a reply to an open message-exchange.
|
void |
select(PickResponseChannel pickResponseChannel,
java.util.Date timeout,
boolean createInstance,
Selector[] selectors)
Non-deterministic selection on incoming message-exchanges.
|
void |
updateMyRoleMex(MyRoleMessageExchangeImpl m) |
buildOutgoingMessage, cancelOutstandingRequests, completedOk, convertEndpointReference, createPartnerRoleMessageExchangeImpl, createScopeInstance, doAsyncReply, execute, fetchEndpointSessionId, fetchMyRoleEndpointReferenceData, fetchMySessionId, fetchPartnerLinkDAO, fetchPartnerRoleEndpointReferenceData, fetchPartnersSessionId, genId, getBaseResourceURI, getBpelProcess, getConfigForPartnerLink, getCurrentEventDateTime, getExpLangRuntime, getMyRequest, getPartnerFault, getPartnerFaultExplanation, getPartnerResponse, getPartnerResponseType, getPid, getProcessClassLoader, getProcessProperty, getProcessQName, getSourceEPR, getSourceSessionId, initializeCorrelation, initializePartnerLinks, initializePartnersSessionId, inputMsgMatch, invocationResponse, isCorrelationInitialized, isPartnerRoleEndpointInitialized, isVariableInitialized, matcherEvent, processOutstandingRequest, readCorrelation, readExtVar, readProperty, readVariable, recoverActivity, releasePartnerMex, reply2, sendEvent, setCurrentEventDateTime, terminate, timerEvent, unregisterActivityForRecovery, writeCorrelation, writeEndpointReference, writeExtVar, writeVariablepublic ReplayerBpelRuntimeContextImpl(BpelProcess bpelProcess, ProcessInstanceDAO dao, PROCESS PROCESS, MyRoleMessageExchangeImpl instantiatingMessageExchange, ReplayerContext context)
public void cancel(TimerResponseChannel timerResponseChannel)
BpelRuntimeContextcancel in interface BpelRuntimeContextcancel in class BpelRuntimeContextImplpublic void checkInvokeExternalPermission()
checkInvokeExternalPermission in class BpelRuntimeContextImplpublic java.lang.String invoke(int aid,
PartnerLinkInstance partnerLink,
javax.wsdl.Operation operation,
org.w3c.dom.Element outgoingMessage,
InvokeResponseChannel channel)
throws FaultException
BpelRuntimeContextImplinvoke in interface BpelRuntimeContextinvoke in class BpelRuntimeContextImplaid - The activity id in the process definition (id of OInvoke)partnerLink - The partner link variable instanceoperation - The wsdl operation.outgoingMessage - The message sent outside as a DOMchannel - Object called back when the response is received.FaultException - When the response is a fault or when the invoke could not be executed
in which case it is one of the bpel standard fault.public void registerTimer(TimerResponseChannel timerChannel, java.util.Date timeToFire)
BpelRuntimeContextregisterTimer in interface BpelRuntimeContextregisterTimer in class BpelRuntimeContextImpltimerChannel - channel for timer notificationtimeToFire - future time to fire timer notificationpublic void registerActivityForRecovery(ActivityRecoveryChannel channel, long activityId, java.lang.String reason, java.util.Date dateTime, org.w3c.dom.Element details, java.lang.String[] actions, int retries)
registerActivityForRecovery in interface BpelRuntimeContextregisterActivityForRecovery in class BpelRuntimeContextImplpublic void completedFault(FaultData faultData)
BpelRuntimeContextcompletedFault in interface BpelRuntimeContextcompletedFault in class BpelRuntimeContextImplBpelRuntimeContext.completedFault(org.apache.ode.bpel.runtime.channels.FaultData)public void reply(PartnerLinkInstance plinkInstnace, java.lang.String opName, java.lang.String mexId, org.w3c.dom.Element msg, javax.xml.namespace.QName fault) throws FaultException
BpelRuntimeContextreply in interface BpelRuntimeContextreply in class BpelRuntimeContextImplmsg - response messagefault - fault name, if this is a fault reply, otherwise nullFaultExceptionpublic void select(PickResponseChannel pickResponseChannel, java.util.Date timeout, boolean createInstance, Selector[] selectors) throws FaultException
BpelRuntimeContextselect in interface BpelRuntimeContextselect in class BpelRuntimeContextImplFaultExceptionpublic ProcessInstanceDAO getDAO()
public static MyRoleMessageExchangeImpl createMyRoleMex(CommunicationType.Exchange e, BpelEngineImpl engine) throws java.lang.Exception
java.lang.Exceptionpublic void updateMyRoleMex(MyRoleMessageExchangeImpl m)
public static void assign(MessageDAO m, org.apache.xmlbeans.XmlObject o) throws java.lang.Exception
java.lang.Exceptionpublic void handleIncomingRequest(MyRoleMessageExchangeImpl mex, java.util.Date currentEventDateTime)