[airavata] branch develop updated: Fixing the bug of producer becomming null

[di...@apache.org]

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

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


The following commit(s) were added to refs/heads/develop by this push:
     new 0cc43ea  Fixing the bug of producer becomming null
0cc43ea is described below

commit 0cc43ea2c3ff2191ca08b6c5bba7659e792539c1
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Wed Jan 16 10:17:56 2019 -0500

    Fixing the bug of producer becomming null
---
 .../apache/airavata/helix/impl/task/parsing/ParsingTriggeringTask.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/ParsingTriggeringTask.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/ParsingTriggeringTask.java
index ca7d5c2..0e275a4 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/ParsingTriggeringTask.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/ParsingTriggeringTask.java
@@ -31,7 +31,7 @@ public class ParsingTriggeringTask extends AiravataTask {
         props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
                 StringSerializer.class.getName());
         props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ProcessCompletionMessageSerializer.class.getName());
-        this.producer = producer;
+        this.producer = new KafkaProducer<String, ProcessCompletionMessage>(props);;
     }
 
     public void submitMessageToParserEngine(ProcessCompletionMessage completionMessage) throws ExecutionException, InterruptedException, ApplicationSettingsException {