airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dimuthu...@apache.org
Subject [airavata] branch develop updated: Changing the split character of ProcessCompletionMessage serialization
Date Wed, 16 Jan 2019 17:15:49 GMT
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 afcb7c2  Changing the split character of ProcessCompletionMessage serialization
afcb7c2 is described below

commit afcb7c2e54ea2ff158bbbc21038b1decf3532d0f
Author: Dimuthu Wannipurage <dimuthu.upeksha2@gmail.com>
AuthorDate: Wed Jan 16 12:15:37 2019 -0500

    Changing the split character of ProcessCompletionMessage serialization
---
 .../impl/task/parsing/kafka/ProcessCompletionMessageDeserializer.java   | 2 +-
 .../impl/task/parsing/kafka/ProcessCompletionMessageSerializer.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/kafka/ProcessCompletionMessageDeserializer.java
b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/kafka/ProcessCompletionMessageDeserializer.java
index 68f0872..bb317c6 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/kafka/ProcessCompletionMessageDeserializer.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/kafka/ProcessCompletionMessageDeserializer.java
@@ -14,7 +14,7 @@ public class ProcessCompletionMessageDeserializer implements Deserializer<Proces
     @Override
     public ProcessCompletionMessage deserialize(String topic, byte[] data) {
         String deserialized = new String(data);
-        String parts[] = deserialized.split(",");
+        String parts[] = deserialized.split(";");
         ProcessCompletionMessage message = new ProcessCompletionMessage();
         message.setProcessId(parts[0]);
         message.setExperimentId(parts[1]);
diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/kafka/ProcessCompletionMessageSerializer.java
b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/kafka/ProcessCompletionMessageSerializer.java
index c64a38e..8204f65 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/kafka/ProcessCompletionMessageSerializer.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/kafka/ProcessCompletionMessageSerializer.java
@@ -14,7 +14,7 @@ public class ProcessCompletionMessageSerializer implements Serializer<ProcessCom
 
     @Override
     public byte[] serialize(String topic, ProcessCompletionMessage data) {
-        String serialized = data.getProcessId() + "," + data.getExperimentId() + "," + data.getGatewayId();
+        String serialized = data.getProcessId() + ";" + data.getExperimentId() + ";" + data.getGatewayId();
         return serialized.getBytes();
     }
 


Mime
View raw message