You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2019/01/16 17:15:49 UTC
[airavata] branch develop updated: Changing the split character of
ProcessCompletionMessage serialization
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 <di...@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();
}