Multiple reader thread support for db client

[simantics/platform.git] / tests / org.simantics.db.tests / src / org / simantics / db / tests / regression / bugs / SimanticsBug1659Test2.java

diff --git a/tests/org.simantics.db.tests/src/org/simantics/db/tests/regression/bugs/SimanticsBug1659Test2.java b/tests/org.simantics.db.tests/src/org/simantics/db/tests/regression/bugs/SimanticsBug1659Test2.java
index 5c44a694c843d09740d4de1e5c5e0ca7847f503b..b7595baed2e78fbf8e7ec03c2b801819677c402d 100644 (file)
--- a/tests/org.simantics.db.tests/src/org/simantics/db/tests/regression/bugs/SimanticsBug1659Test2.java
+++ b/tests/org.simantics.db.tests/src/org/simantics/db/tests/regression/bugs/SimanticsBug1659Test2.java
@@ -4,13 +4,14 @@ import java.util.UUID;
 
 import org.junit.Test;
 import org.simantics.databoard.Bindings;
+import org.simantics.db.AsyncReadGraph;
 import org.simantics.db.ReadGraph;
 import org.simantics.db.Resource;
 import org.simantics.db.Session;
 import org.simantics.db.WriteGraph;
 import org.simantics.db.WriteOnlyGraph;
 import org.simantics.db.common.primitiverequest.PossibleObject;
-import org.simantics.db.common.request.ReadRequest;
+import org.simantics.db.common.request.AsyncReadRequest;
 import org.simantics.db.common.request.WriteOnlyRequest;
 import org.simantics.db.common.request.WriteRequest;
 import org.simantics.db.exception.DatabaseException;
@@ -99,9 +100,10 @@ public class SimanticsBug1659Test2 extends ExistingDatabaseTest {
             }
         }
     }
-    class Query extends ReadRequest {
+    class Query extends AsyncReadRequest {
         @Override
-        public void run(ReadGraph g) throws DatabaseException {
+        public void run(AsyncReadGraph g) {
+               try {
             Layer0 l0 = Layer0.getInstance(g);
             for (Resource r : g.getObjects(testRoot, l0.ConsistsOf)) {
                 if (DEBUG)
@@ -142,6 +144,9 @@ public class SimanticsBug1659Test2 extends ExistingDatabaseTest {
                     }
                 }
             }
+               } catch (DatabaseException e) {
+                       e.printStackTrace();
+               }
         }
     }
     class Listener implements SyncListener<Resource> {