From 35b64bebaa49460dc53a7f54ed6f56f927008822 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Wed, 4 Mar 2015 16:56:41 +0300
Subject: [PATCH] addAndGet serialization fixed. #120

---
 src/main/java/com/lambdaworks/redis/RedisAsyncConnection.java | 4 ++--
 src/test/java/org/redisson/RedissonMapTest.java               | 4 +++-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/lambdaworks/redis/RedisAsyncConnection.java b/src/main/java/com/lambdaworks/redis/RedisAsyncConnection.java
index c6b3c0f98..74ad96655 100644
--- a/src/main/java/com/lambdaworks/redis/RedisAsyncConnection.java
+++ b/src/main/java/com/lambdaworks/redis/RedisAsyncConnection.java
@@ -379,12 +379,12 @@ public class RedisAsyncConnection<K, V> extends ChannelInboundHandlerAdapter {
     }
 
     public Future<Long> hincrby(K key, K field, long amount) {
-        CommandArgs<K, V> args = new CommandArgs<K, V>(codec).addKey(key).addKey(field).add(amount);
+        CommandArgs<K, V> args = new CommandArgs<K, V>(codec).addKey(key).addMapKey(field).add(amount);
         return dispatch(HINCRBY, new IntegerOutput<K, V>(codec), args);
     }
 
     public Future<String> hincrbyfloat(K key, K field, String amount) {
-        CommandArgs<K, V> args = new CommandArgs<K, V>(codec).addKey(key).addKey(field).add(amount);
+        CommandArgs<K, V> args = new CommandArgs<K, V>(codec).addKey(key).addMapKey(field).add(amount);
         return dispatch(HINCRBYFLOAT, new StatusOutput<K, V>(codec), args);
     }
 
diff --git a/src/test/java/org/redisson/RedissonMapTest.java b/src/test/java/org/redisson/RedissonMapTest.java
index 51fbe068b..bebfe9467 100644
--- a/src/test/java/org/redisson/RedissonMapTest.java
+++ b/src/test/java/org/redisson/RedissonMapTest.java
@@ -118,7 +118,7 @@ public class RedissonMapTest extends BaseTest {
         }
 
     }
-
+    
     @Test
     public void testAddAndGet() throws InterruptedException {
         RMap<Integer, Integer> map = redisson.getMap("getAll");
@@ -126,6 +126,8 @@ public class RedissonMapTest extends BaseTest {
 
         Integer res = map.addAndGet(1, 12);
         Assert.assertEquals(112, (int)res);
+        res = map.get(1);
+        Assert.assertEquals(112, (int)res);
     }
 
     @Test