You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2011/09/14 19:58:23 UTC
svn commit: r1170749 -
/incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/publish/WSMPublisher.java
Author: lahiru
Date: Wed Sep 14 17:58:22 2011
New Revision: 1170749
URL: http://svn.apache.org/viewvc?rev=1170749&view=rev
Log:
adding notification funcationality to gfac-axis2.
Modified:
incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/publish/WSMPublisher.java
Modified: incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/publish/WSMPublisher.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/publish/WSMPublisher.java?rev=1170749&r1=1170748&r2=1170749&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/publish/WSMPublisher.java (original)
+++ incubator/airavata/trunk/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/publish/WSMPublisher.java Wed Sep 14 17:58:22 2011
@@ -57,8 +57,6 @@ public class WSMPublisher extends Abstra
public WSMPublisher(int capacity, boolean defaultAsync, String brokerLoc, String topic) throws IOException {
super(capacity, defaultAsync);
- URL configURL = ClassLoader.getSystemResource(ConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
broker = new WseMsgBrokerClient();
brokerEpr = broker.createEndpointReference(brokerLoc, topic);
broker.init(brokerEpr.getAddress());
@@ -68,12 +66,10 @@ public class WSMPublisher extends Abstra
throws WorkflowTrackingException {
super(capacity, defaultAsync);
try {
- URL configURL = ClassLoader.getSystemResource(ConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
brokerEpr = brokerEpr_;
broker = new WseMsgBrokerClient();
broker.init(brokerEpr_.getAddress());
- } catch (IOException e) {
+ } catch (Exception e) {
throw new WorkflowTrackingException(e);
}
}
@@ -85,11 +81,7 @@ public class WSMPublisher extends Abstra
}
public WSMPublisher(int capacity, boolean defaultAsync, String brokerEpr_, boolean isXmlEpr) throws IOException {
-
super(capacity, defaultAsync);
- URL configURL = ClassLoader.getSystemResource(ConfigKeys.CONFIG_FILE_NAME);
- configs.load(configURL.openStream());
-
if (!isXmlEpr) {
brokerEpr = new EndpointReference(brokerEpr_);// EndpointReferenceHelper.fro(brokerEpr_);