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, writeVariable
public ReplayerBpelRuntimeContextImpl(BpelProcess bpelProcess, ProcessInstanceDAO dao, PROCESS PROCESS, MyRoleMessageExchangeImpl instantiatingMessageExchange, ReplayerContext context)
public void cancel(TimerResponseChannel timerResponseChannel)
BpelRuntimeContext
cancel
in interface BpelRuntimeContext
cancel
in class BpelRuntimeContextImpl
public void checkInvokeExternalPermission()
checkInvokeExternalPermission
in class BpelRuntimeContextImpl
public java.lang.String invoke(int aid, PartnerLinkInstance partnerLink, javax.wsdl.Operation operation, org.w3c.dom.Element outgoingMessage, InvokeResponseChannel channel) throws FaultException
BpelRuntimeContextImpl
invoke
in interface BpelRuntimeContext
invoke
in class BpelRuntimeContextImpl
aid
- 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)
BpelRuntimeContext
registerTimer
in interface BpelRuntimeContext
registerTimer
in class BpelRuntimeContextImpl
timerChannel
- 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 BpelRuntimeContext
registerActivityForRecovery
in class BpelRuntimeContextImpl
public void completedFault(FaultData faultData)
BpelRuntimeContext
completedFault
in interface BpelRuntimeContext
completedFault
in class BpelRuntimeContextImpl
BpelRuntimeContext.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
BpelRuntimeContext
reply
in interface BpelRuntimeContext
reply
in class BpelRuntimeContextImpl
msg
- response messagefault
- fault name, if this is a fault reply, otherwise null
FaultException
public void select(PickResponseChannel pickResponseChannel, java.util.Date timeout, boolean createInstance, Selector[] selectors) throws FaultException
BpelRuntimeContext
select
in interface BpelRuntimeContext
select
in class BpelRuntimeContextImpl
FaultException
public ProcessInstanceDAO getDAO()
public static MyRoleMessageExchangeImpl createMyRoleMex(CommunicationType.Exchange e, BpelEngineImpl engine) throws java.lang.Exception
java.lang.Exception
public void updateMyRoleMex(MyRoleMessageExchangeImpl m)
public static void assign(MessageDAO m, org.apache.xmlbeans.XmlObject o) throws java.lang.Exception
java.lang.Exception
public void handleIncomingRequest(MyRoleMessageExchangeImpl mex, java.util.Date currentEventDateTime)