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

ReceiveUnitImpl.java edited online with Bitbucket

master
Boris Bendyukov 2014-01-16 11:29:06 +00:00
parent ad4d88f37d
commit ad282fbc93
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ojc-core/bpelse/bpelcore/src/com/sun/jbi/engine/bpel/core/bpel/model/runtime/impl/ReceiveUnitImpl.java
View File

@ -139,8 +139,10 @@ public class ReceiveUnitImpl extends ActivityUnitImpl {
//TODO: This time we assume that the message will be found. Is that a valid assumption? //TODO: This time we assume that the message will be found. Is that a valid assumption?
Object[] result = procMgr.receiveRequestOrPutInPendingQueue(mWaitingForEvent, frame); Object[] result = procMgr.receiveRequestOrPutInPendingQueue(mWaitingForEvent, frame);
MessageContainer request = (MessageContainer) result[0]; MessageContainer request = (MessageContainer) result[0];
if(request != null) if(request != null) {
receive.setMessageExchange(request.getId());
mContext.addRequest(receive, request); mContext.addRequest(receive, request);
}
//Post event //Post event
postVarEvent (receive.getRVariable(), request, rObjs, bpit.getCallFrame()); postVarEvent (receive.getRVariable(), request, rObjs, bpit.getCallFrame());
@ -242,6 +244,7 @@ public class ReceiveUnitImpl extends ActivityUnitImpl {
return false; return false;
} }
} }
receive.setMessageExchange(request.getId());
mContext.addRequest(receive, request); mContext.addRequest(receive, request);
frame.onLineChange(this); frame.onLineChange(this);