svn commit: r1411416 - /airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/invoker/MsgBoxWsaResponsesCorrelator.java

[la...@apache.org]

Author: lahiru
Date: Mon Nov 19 21:12:26 2012
New Revision: 1411416

URL: http://svn.apache.org/viewvc?rev=1411416&view=rev
Log:
fixing https://issues.apache.org/jira/browse/AIRAVATA-648.

Modified:
    airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/invoker/MsgBoxWsaResponsesCorrelator.java

Modified: airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/invoker/MsgBoxWsaResponsesCorrelator.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/invoker/MsgBoxWsaResponsesCorrelator.java?rev=1411416&r1=1411415&r2=1411416&view=diff
==============================================================================
--- airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/invoker/MsgBoxWsaResponsesCorrelator.java (original)
+++ airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/invoker/MsgBoxWsaResponsesCorrelator.java Mon Nov 19 21:12:26 2012
@@ -106,6 +106,10 @@ public class MsgBoxWsaResponsesCorrelato
                         System.out.println(Thread.currentThread().getName());
                         WSIFMessageElement e = new WSIFMessageElement(m);
                         this.invoker.setOutputMessage(e);
+                        //ideally there are no multiple messages, so we can return from this thread at this point
+                        //otherwise this thread will keep running forever for each worfklow node, so there can be large
+                        // number of waiting threads in an airavata deployment
+                        return;
                     } catch (Throwable e) {
                         e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
                     }