Merge "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 866323bab9d1132d16d86eb529901e789ed3495c..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);
 
-            graph.asyncRequest(new ResourceRead3<Boolean>(issue, model, source) {
+            graph.syncRequest(new ResourceRead3<Boolean>(issue, model, source) {
 
                 @Override
                 public Boolean perform(ReadGraph graph) throws DatabaseException {
@@ -250,7 +250,7 @@ public class IssueUtils {
             sources.put(source, Pair.make(is, listener));
 
             if (isListeningTracker) {
-                graph.asyncRequest(
+                graph.syncRequest(
                         new Objects(source, ISSUE.IssueSource_Manages),
                         new IssueSourceManagedIssuesListener(disposed, source, model));
             }
@@ -278,7 +278,7 @@ public class IssueUtils {
     public static Disposable listenActiveProjectIssueSources(RequestProcessor processor, Resource project) throws DatabaseException {
         final AtomicBoolean disposed = new AtomicBoolean(false);
         processor.syncRequest(
-                new ActiveProjectIssueSources(project),
+                new ActiveProjectIssueSources(project, IssueResource.getInstance(processor).ContinuousIssueSource),
                 new ActiveIssueSourceListener(disposed));
         return new Disposable() {
             @Override