vitalif
/
openesb-components
mirror of https://github.com/vitalif/openesb-components
1
0
Fork 0
Code Issues Releases Wiki Activity

StateManagerImpl.java edited online with Bitbucket

master
Boris Bendyukov 2014-01-17 07:30:48 +00:00
parent 9cbac9f3cb
commit d7be45c508
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
ojc-core/bpelse/bpelcore/src/com/sun/jbi/engine/bpel/core/bpel/persist/impl/StateManagerImpl.java
View File

@ -393,8 +393,22 @@ public class StateManagerImpl implements StateManager {
String partnerlink = qCRMPDBO.getPartnerLink();
String oper = qCRMPDBO.getOperation();
String crmpUpdateListValue = bpId + partnerlink + oper;
String crmpInvokeId = qCRMPDBO.getCRMPInvokeId();
long replyVarId = qCRMPDBO.getReplyVariableId();
String msgExch = qCRMPDBO.getBpelMessageExchange();
BPELProcessInstanceImpl instImpl = (BPELProcessInstanceImpl) processInstance;
instImpl.addToCRMPUpdateList(crmpUpdateListValue);
if (replyVarId == -1) {
RBPELProcess proc = instImpl.getBPELProcessManager().getBPELProcess();
RStartElement actStart = proc.getStartElement(partnerlink, oper, msgExch);
RVariable rVar = actStart.getRVariable();
RuntimeVariable runVar = instImpl.getRuntimeVariable(rVar);
MessageContainer con = MessageContainerFactory.createMessage(msgExch, runVar.getWSMessage(), crmpInvokeId, null);
instImpl.getBPELProcessManager().addCRMPReqForRecoveringInsts(crmpUpdateListValue, con);
}
}
}
} catch (Throwable t) {