Strolch
/
strolch
mirror of https://github.com/strolch-li/strolch.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[New] Add SimpleExecution.runWithFreshAction()

This commit is contained in:
Robert von Burg 2020-07-15 15:51:28 +02:00
parent b071dafc11
commit 7b2a516b38
1 changed files with 46 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
li.strolch.service/src/main/java/li/strolch/execution/policy/SimpleExecution.java
View File

@ -1,12 +1,17 @@
package li.strolch.execution.policy;
import li.strolch.model.log.LogMessage;
import java.util.function.BiConsumer;
import java.util.function.Consumer;
import li.strolch.exception.StrolchException;
import li.strolch.handler.operationslog.OperationsLog;
import li.strolch.model.State;
import li.strolch.model.activity.Action;
import li.strolch.model.log.LogMessage;
import li.strolch.model.timevalue.impl.FloatValue;
import li.strolch.model.timevalue.impl.ValueChange;
import li.strolch.persistence.api.StrolchTransaction;
import li.strolch.privilege.model.PrivilegeContext;
/**
* <p>
@ -88,4 +93,44 @@ public class SimpleExecution extends ExecutionPolicy {
addMessage(message);
getController().asyncToWarning(message.getLocator());
}
protected StrolchTransaction openLocalTx(PrivilegeContext ctx, boolean readOnly) throws StrolchException {
return getContainer().getRealm(ctx.getCertificate()).openTx(ctx.getCertificate(), getClass(), readOnly);
}
protected void runWithFreshAction(Consumer<Action> consumer) {
runWithFreshAction(consumer, true);
}
protected void runWithFreshAction(Consumer<Action> consumer, boolean readOnly) {
try {
runAsAgent(ctx -> {
try (StrolchTransaction tx = openLocalTx(ctx, readOnly)) {
tx.lock(this.actionLoc.trim(3));
Action action = tx.findElement(this.actionLoc);
consumer.accept(action);
}
});
} catch (Exception e) {
logger.error("Failed to perform consumer " + consumer.toString(), e);
}
}
protected void runWithFreshAction(BiConsumer<StrolchTransaction, Action> consumer) {
runWithFreshAction(consumer, true);
}
protected void runWithFreshAction(BiConsumer<StrolchTransaction, Action> consumer, boolean readOnly) {
try {
runAsAgent(ctx -> {
try (StrolchTransaction tx = openLocalTx(ctx, readOnly)) {
tx.lock(this.actionLoc.trim(3));
Action action = tx.findElement(this.actionLoc);
consumer.accept(tx, action);
}
});
} catch (Exception e) {
logger.error("Failed to perform consumer " + consumer.toString(), e);
}
}
}