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

[lahiru]

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.
                     }