[New] ExecutionHandler.triggerExecution(realm) is now public
This commit is contained in:
parent
0badb0fc01
commit
ffbbe3c4bb
|
@ -100,6 +100,19 @@ public class EventBasedExecutionHandler extends ExecutionHandler {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void triggerExecution(String realm) {
|
||||||
|
synchronized (this.registeredActivities) {
|
||||||
|
Set<Locator> locators = this.registeredActivities.getSet(realm);
|
||||||
|
if (locators != null) {
|
||||||
|
for (Locator locator : locators) {
|
||||||
|
// execute async
|
||||||
|
toExecution(realm, locator);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void toExecution(String realm, Locator locator) {
|
public void toExecution(String realm, Locator locator) {
|
||||||
this.executorService.execute(() -> {
|
this.executorService.execute(() -> {
|
||||||
|
@ -184,8 +197,8 @@ public class EventBasedExecutionHandler extends ExecutionHandler {
|
||||||
KEY_DEFAULT_ACTIVITY_ARCHIVAL);
|
KEY_DEFAULT_ACTIVITY_ARCHIVAL);
|
||||||
}
|
}
|
||||||
|
|
||||||
ActivityArchivalPolicy archivalPolicy = getComponent(PolicyHandler.class).getPolicy(policyDef,
|
PolicyHandler policyHandler = getComponent(PolicyHandler.class);
|
||||||
tx);
|
ActivityArchivalPolicy archivalPolicy = policyHandler.getPolicy(policyDef, tx);
|
||||||
archivalPolicy.archive(activity);
|
archivalPolicy.archive(activity);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -267,23 +280,6 @@ public class EventBasedExecutionHandler extends ExecutionHandler {
|
||||||
triggerExecution(realm);
|
triggerExecution(realm);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Triggers a to execution for all registered activities in the given realm
|
|
||||||
*
|
|
||||||
* @param realm
|
|
||||||
*/
|
|
||||||
private void triggerExecution(String realm) {
|
|
||||||
synchronized (this.registeredActivities) {
|
|
||||||
Set<Locator> locators = this.registeredActivities.getSet(realm);
|
|
||||||
if (locators != null) {
|
|
||||||
for (Locator locator : locators) {
|
|
||||||
// execute async
|
|
||||||
toExecution(realm, locator);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void toWarning(String realm, Locator actionLoc, PrivilegeContext ctx) {
|
private void toWarning(String realm, Locator actionLoc, PrivilegeContext ctx) {
|
||||||
try (StrolchTransaction tx = openTx(realm, ctx.getCertificate(), SetActionToExecutedCommand.class)) {
|
try (StrolchTransaction tx = openTx(realm, ctx.getCertificate(), SetActionToExecutedCommand.class)) {
|
||||||
Locator rootElemLoc = actionLoc.trim(3);
|
Locator rootElemLoc = actionLoc.trim(3);
|
||||||
|
|
|
@ -55,6 +55,14 @@ public abstract class ExecutionHandler extends StrolchComponent {
|
||||||
*/
|
*/
|
||||||
public abstract void removeFromExecution(String realm, Locator activityLoc);
|
public abstract void removeFromExecution(String realm, Locator activityLoc);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Triggers a to execution for all registered activities in the given realm
|
||||||
|
*
|
||||||
|
* @param realm
|
||||||
|
* the realm to trigger execution for
|
||||||
|
*/
|
||||||
|
public abstract void triggerExecution(String realm);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* <p>
|
* <p>
|
||||||
* Returns the {@link DelayedExecutionTimer}
|
* Returns the {@link DelayedExecutionTimer}
|
||||||
|
@ -118,4 +126,5 @@ public abstract class ExecutionHandler extends StrolchComponent {
|
||||||
* the {@link Locator} of the {@link Action}
|
* the {@link Locator} of the {@link Action}
|
||||||
*/
|
*/
|
||||||
public abstract void toError(String realm, Locator actionLoc);
|
public abstract void toError(String realm, Locator actionLoc);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue