From 06f847ac76d98b2f8582ed1669c0526e6e322fce Mon Sep 17 00:00:00 2001
From: mathieucarbou <mathieu.carbou@gmail.com>
Date: Wed, 25 Feb 2015 12:12:25 -0500
Subject: [PATCH] KryoCodec: do not encode / decode keys #127
 (https://github.com/mrniko/redisson/issues/127)

---
 src/main/java/org/redisson/codec/KryoCodec.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
 mode change 100644 => 100755 src/main/java/org/redisson/codec/KryoCodec.java

diff --git a/src/main/java/org/redisson/codec/KryoCodec.java b/src/main/java/org/redisson/codec/KryoCodec.java
old mode 100644
new mode 100755
index 2b5d9ce0f..78afdd448
--- a/src/main/java/org/redisson/codec/KryoCodec.java
+++ b/src/main/java/org/redisson/codec/KryoCodec.java
@@ -18,6 +18,7 @@ package org.redisson.codec;
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.nio.ByteBuffer;
+import java.nio.charset.Charset;
 import java.util.Queue;
 import java.util.concurrent.ConcurrentLinkedQueue;
 
@@ -126,12 +127,12 @@ public class KryoCodec implements RedissonCodec {
 
     @Override
     public byte[] encodeKey(Object key) {
-        return encodeValue(key);
+        return key.toString().getBytes(Charset.forName("ASCII"));
     }
 
     @Override
     public Object decodeKey(ByteBuffer bytes) {
-        return decode(bytes);
+        return new String(bytes.array(), bytes.arrayOffset() + bytes.position(), bytes.limit(), Charset.forName("ASCII"));
     }
 
     @Override