You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/05/19 23:52:35 UTC
[10/24] git commit: Added json msg and id parsing.
Added json msg and id parsing.
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/32b37185
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/32b37185
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/32b37185
Branch: refs/heads/master
Commit: 32b371857ddec5669f65fa779f6a0b098c1cb0a1
Parents: 63afb94
Author: John Gilmore <jg...@ml.sun.ac.za>
Authored: Wed Oct 9 16:40:05 2013 +0200
Committer: John Gilmore <jg...@ml.sun.ac.za>
Committed: Wed Oct 9 16:40:05 2013 +0200
----------------------------------------------------------------------
.../src/jvm/backtype/storm/multilang/JsonSerializer.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/32b37185/storm-core/src/jvm/backtype/storm/multilang/JsonSerializer.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/multilang/JsonSerializer.java b/storm-core/src/jvm/backtype/storm/multilang/JsonSerializer.java
index 8afa4bb..70d8e5b 100644
--- a/storm-core/src/jvm/backtype/storm/multilang/JsonSerializer.java
+++ b/storm-core/src/jvm/backtype/storm/multilang/JsonSerializer.java
@@ -81,6 +81,12 @@ public class JsonSerializer implements ISerializer {
String command = (String) msg.get("command");
shellMsg.setCommand(command);
+ String id = (String) msg.get("id");
+ shellMsg.setId(id);
+
+ String log = (String) msg.get("msg");
+ shellMsg.setMsg(log);
+
String stream = (String) msg.get("stream");
if (stream == null)
stream = Utils.DEFAULT_STREAM_ID;
@@ -92,7 +98,7 @@ public class JsonSerializer implements ISerializer {
} else {
shellMsg.setTask(0);
}
-
+
Object need_task_ids = msg.get("need_task_ids");
if (need_task_ids == null || ((Boolean) need_task_ids).booleanValue()) {
shellMsg.setNeedTaskIds(true);