diff options
Diffstat (limited to 'src/main/java/com/c2kernel/lifecycle/instance/predefined')
| -rw-r--r-- | src/main/java/com/c2kernel/lifecycle/instance/predefined/Import.java | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/main/java/com/c2kernel/lifecycle/instance/predefined/Import.java b/src/main/java/com/c2kernel/lifecycle/instance/predefined/Import.java index 8bcaa45..cbdc33b 100644 --- a/src/main/java/com/c2kernel/lifecycle/instance/predefined/Import.java +++ b/src/main/java/com/c2kernel/lifecycle/instance/predefined/Import.java @@ -77,20 +77,20 @@ public class Import extends PredefinedStep // write event, outcome and viewpoints to storage
int syskey = getItemEntityPath().getSysKey();
TransactionManager storage = Gateway.getStorage();
-
- History hist = new History(syskey, this);
+ Object locker = getWf();
+ History hist = getWf().getHistory();
Event event = hist.addEvent(agent.getAgentName(), getCurrentAgentRole(), transitionID, getName(), getPath(), getType(), schemaName, schemaVersion, viewpoint, getCurrentState(), timestamp);
try {
- storage.put(syskey, new Outcome(event.getID(), requestData, schemaName, schemaVersion), this);
- storage.put(syskey, new Viewpoint(syskey, schemaName, viewpoint, schemaVersion, event.getID()), this);
+ storage.put(syskey, new Outcome(event.getID(), requestData, schemaName, schemaVersion), locker);
+ storage.put(syskey, new Viewpoint(syskey, schemaName, viewpoint, schemaVersion, event.getID()), locker);
if (!"last".equals(viewpoint))
- storage.put(syskey, new Viewpoint(syskey, schemaName, "last", schemaVersion, event.getID()), this);
+ storage.put(syskey, new Viewpoint(syskey, schemaName, "last", schemaVersion, event.getID()), locker);
} catch (ClusterStorageException e) {
Logger.error(e);
- storage.abort(this);
+ storage.abort(locker);
throw new InvalidDataException("Could not store imported outcome. Rolled back.");
}
- storage.commit(this);
+ storage.commit(locker);
}
}
|