[airavata] branch staging updated: Adding main method for parser wm

[dimuthuupe]

This is an automated email from the ASF dual-hosted git repository.

dimuthuupe pushed a commit to branch staging
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/staging by this push:
     new 1162b55  Adding main method for parser wm
1162b55 is described below

commit 1162b5561824bec0b7f7132cba525f6c05e19394
Author: Dimuthu Wannipurage <dimuthu.upeks...@gmail.com>
AuthorDate: Fri Jul 26 03:47:49 2019 -0400

    Adding main method for parser wm
---
 .../ansible/inventories/scigap/staging/group_vars/all/vars.yml      | 2 +-
 .../apache/airavata/helix/impl/workflow/ParserWorkflowManager.java  | 6 ++++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/dev-tools/ansible/inventories/scigap/staging/group_vars/all/vars.yml 
b/dev-tools/ansible/inventories/scigap/staging/group_vars/all/vars.yml
index 24baee7..325c9e4 100644
--- a/dev-tools/ansible/inventories/scigap/staging/group_vars/all/vars.yml
+++ b/dev-tools/ansible/inventories/scigap/staging/group_vars/all/vars.yml
@@ -180,5 +180,5 @@ parser_broker_url: "{{ groups['kafka'][0] }}:{{ 
kafka_listener_port }}"
 parser_broker_topic: "completed-messages"
 parser_broker_consumer_group: "ParsingConsumer"
 # TODO: update storage resource id
-parser_storage_resource_id: 
"pgadev.scigap.org_7ddf28fd-d503-4ff8-bbc5-3279a7c3b99e"
+parser_storage_resource_id: 
"pga.staging.scigap.org_aa63ffa0-a99f-4885-8f4b-81e3c4c4d737"
 parser_broker_publisher_id: "ParserProducer"
diff --git 
a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/ParserWorkflowManager.java
 
b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/ParserWorkflowManager.java
index bb27638..e9d52de 100644
--- 
a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/ParserWorkflowManager.java
+++ 
b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/ParserWorkflowManager.java
@@ -62,6 +62,12 @@ public class ParserWorkflowManager extends WorkflowManager {
                 
Boolean.parseBoolean(ServerSettings.getSetting("post.workflow.manager.loadbalance.clusters")));
     }
 
+    public static void main(String[] args) throws Exception {
+        ParserWorkflowManager manager = new ParserWorkflowManager();
+        manager.init();
+        manager.runConsumer();
+    }
+
     private void init() throws Exception {
         super.initComponents();
     }