Multiple reader thread support for db client

[simantics/platform.git] / bundles / org.simantics.issues.common / src / org / simantics / issues / common / IssueUtils.java

diff --git a/bundles/org.simantics.issues.common/src/org/simantics/issues/common/IssueUtils.java b/bundles/org.simantics.issues.common/src/org/simantics/issues/common/IssueUtils.java
index bb0c8a5b189c1ee5f0b11905f18e3cad4bae1183..ecc6b20cc9c517b6e04a8e0691821466b4961478 100644 (file)
--- a/bundles/org.simantics.issues.common/src/org/simantics/issues/common/IssueUtils.java
+++ b/bundles/org.simantics.issues.common/src/org/simantics/issues/common/IssueUtils.java
@@ -184,7 +184,7 @@ public class IssueUtils {
         public void add(ReadGraph graph, final Resource issue) throws DatabaseException {
             IssueValidityListener listener = new IssueValidityListener(issue);
 
         public void add(ReadGraph graph, final Resource issue) throws DatabaseException {
             IssueValidityListener listener = new IssueValidityListener(issue);
 

-            graph.asyncRequest(new ResourceRead3<Boolean>(issue, model, source) {
+            graph.syncRequest(new ResourceRead3<Boolean>(issue, model, source) {

 
                 @Override
                 public Boolean perform(ReadGraph graph) throws DatabaseException {
 
                 @Override
                 public Boolean perform(ReadGraph graph) throws DatabaseException {


@@ -250,7 +250,7 @@ public class IssueUtils {
             sources.put(source, Pair.make(is, listener));
 
             if (isListeningTracker) {
             sources.put(source, Pair.make(is, listener));
 
             if (isListeningTracker) {

-                graph.asyncRequest(
+                graph.syncRequest(

                         new Objects(source, ISSUE.IssueSource_Manages),
                         new IssueSourceManagedIssuesListener(disposed, source, model));
             }
                         new Objects(source, ISSUE.IssueSource_Manages),
                         new IssueSourceManagedIssuesListener(disposed, source, model));
             }