airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject svn commit: r1169928 - /incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/AbstractNotifier.java
Date Mon, 12 Sep 2011 21:15:51 GMT
Author: lahiru
Date: Mon Sep 12 21:15:50 2011
New Revision: 1169928

URL: http://svn.apache.org/viewvc?rev=1169928&view=rev
Log:
fixing the error when invoking gfac service using xbaya.

Modified:
    incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/AbstractNotifier.java

Modified: incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/AbstractNotifier.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/AbstractNotifier.java?rev=1169928&r1=1169927&r2=1169928&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/AbstractNotifier.java
(original)
+++ incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/AbstractNotifier.java
Mon Sep 12 21:15:50 2011
@@ -136,7 +136,11 @@ public abstract class AbstractNotifier {
             if (context.getPublisherImpl() != null) {
                 publisher = PublisherFactory.createSomePublisher(context.getPublisherImpl(),
context);
             } else {
-                publisher = new WSMPublisher(100, context.isEnableAsyncPublishing(), context.getBrokerEpr().getAddress(),context.getTopic());
+                if(context.getTopic() == null){
+                    publisher = new WSMPublisher(100,context.isEnableAsyncPublishing(),context.getBrokerEpr().getAddress(),false);
+                }else{
+                    publisher = new WSMPublisher(100, context.isEnableAsyncPublishing(),
context.getBrokerEpr().getAddress(),context.getTopic());
+                }
             }
             publishermap.put(context.getBrokerEpr(), publisher);
         }



Mime
View raw message