ignored distributed flow for internal configuration API
@@ -163,6 +163,9 @@ public class OSharedContextEmbedded extends OSharedContext {
}
public synchronized ODocument loadConfig(ODatabaseSession session, String name) {
+ return (ODocument)
+ OScenarioThreadLocal.executeAsDistributed(
+ () -> {
assert !session.getTransaction().isActive();
String propertyName = "__config__" + name;
String id = storage.getConfiguration().getProperty(propertyName);
@@ -174,6 +177,7 @@ public class OSharedContextEmbedded extends OSharedContext {
} else {
return null;
}
+ });
}
/**
@@ -184,6 +188,8 @@ public class OSharedContextEmbedded extends OSharedContext {
* @param value
*/
public synchronized void saveConfig(ODatabaseSession session, String name, ODocument value) {
+ OScenarioThreadLocal.executeAsDistributed(
+ () -> {
assert !session.getTransaction().isActive();
String propertyName = "__config__" + name;
String id = storage.getConfiguration().getProperty(propertyName);
@@ -197,5 +203,7 @@ public class OSharedContextEmbedded extends OSharedContext {
ORID recordId = session.save(value, "internal").getIdentity();
storage.setProperty(propertyName, recordId.toString());
}
+ return null;
+ });
}
}
