Repository: ignite Updated Branches: refs/heads/ignite-5932 13a1bccf8 -> fc60925e0
IGNITE-6127 Fixed bytes encoding. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0f3f7d20 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0f3f7d20 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0f3f7d20 Branch: refs/heads/ignite-5932 Commit: 0f3f7d20048a13b561ddcac4537f15c2ce9bc8ed Parents: b8b7c50 Author: Alexey Kuznetsov <[email protected]> Authored: Thu Oct 12 22:48:35 2017 +0700 Committer: Alexey Kuznetsov <[email protected]> Committed: Thu Oct 12 22:48:35 2017 +0700 ---------------------------------------------------------------------- .../apache/ignite/console/agent/handlers/AbstractListener.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/0f3f7d20/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/agent/handlers/AbstractListener.java ---------------------------------------------------------------------- diff --git a/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/agent/handlers/AbstractListener.java b/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/agent/handlers/AbstractListener.java index 2eec89b..fc4daef 100644 --- a/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/agent/handlers/AbstractListener.java +++ b/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/agent/handlers/AbstractListener.java @@ -20,6 +20,7 @@ package org.apache.ignite.console.agent.handlers; import io.socket.client.Ack; import io.socket.emitter.Emitter; import java.io.ByteArrayOutputStream; +import java.nio.charset.Charset; import java.util.Arrays; import java.util.Collections; import java.util.Map; @@ -39,6 +40,9 @@ import static org.apache.ignite.console.agent.AgentUtils.toJSON; * Base class for web socket handlers. */ abstract class AbstractListener implements Emitter.Listener { + /** UTF8 charset. */ + private static final Charset UTF8 = Charset.forName("UTF-8"); + /** */ private ExecutorService pool; @@ -81,7 +85,7 @@ abstract class AbstractListener implements Emitter.Listener { Base64OutputStream b64os = new Base64OutputStream(baos); GZIPOutputStream gzip = new GZIPOutputStream(b64os); - gzip.write(restRes.getData().getBytes()); + gzip.write(restRes.getData().getBytes(UTF8)); gzip.close();
