midsuit
/
core-jgi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

IDEMPIERE-4186 allow workflow to be suspended until after commit of actual transaction

This commit is contained in:
mschnbeck 2020-01-31 19:47:05 +01:00 committed by Carlos Ruiz
parent 7fc71f8e9e
commit f1e9b23029
1 changed files with 42 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
org.adempiere.base/src/org/compiere/wf/MWFActivity.java
View File

@ -66,6 +66,7 @@ import org.compiere.util.Env;
import org.compiere.util.Msg;
import org.compiere.util.Trace;
import org.compiere.util.Trx;
import org.compiere.util.TrxEventListener;
import org.compiere.util.Util;
/**
@ -1007,6 +1008,8 @@ public class MWFActivity extends X_AD_WF_Activity implements Runnable
Calendar cal = Calendar.getInstance();
cal.add(Calendar.MINUTE, m_node.getWaitTime());
setEndWaitTime(new Timestamp(cal.getTimeInMillis()));
if (m_node.getWaitTime() == -1)
prepareCommitEvent();
return false; // not done
}
@ -1979,5 +1982,44 @@ public class MWFActivity extends X_AD_WF_Activity implements Runnable
}
return sb.toString();
} // getSummary
private void prepareCommitEvent()
{
Trx trx = null;
if (get_TrxName() == null)
{
return; // no transaction, nothing to commit
}
MWFActivity activity = new MWFActivity (getCtx(), get_ID(), get_TrxName());
trx = Trx.get(get_TrxName(), true);
trx.addTrxEventListener(new TrxListener(activity));
}
static class TrxListener implements TrxEventListener {
private MWFActivity activity;
protected TrxListener(MWFActivity activity) {
this.activity = activity;
}
@Override
public void afterRollback(Trx trx, boolean success) {
}
@Override
public void afterCommit(Trx trx, boolean success) {
if (success) {
trx.removeTrxEventListener(this);
activity.setWFState (StateEngine.STATE_Completed);
}
}
@Override
public void afterClose(Trx trx) {
trx.removeTrxEventListener(this);
}
}
} // MWFActivity