diff --git a/src/main/java/com/lambdaworks/redis/RedisAsyncConnection.java b/src/main/java/com/lambdaworks/redis/RedisAsyncConnection.java index bc3959b9f..596066a0a 100644 --- a/src/main/java/com/lambdaworks/redis/RedisAsyncConnection.java +++ b/src/main/java/com/lambdaworks/redis/RedisAsyncConnection.java @@ -626,7 +626,7 @@ public class RedisAsyncConnection extends ChannelInboundHandlerAdapter { } public Future sadd(K key, V... members) { - CommandArgs args = new CommandArgs(codec).addKey(key).addMapValues(members); + CommandArgs args = new CommandArgs(codec).addKey(key).addValues(members); return dispatch(SADD, new IntegerOutput(codec), args); } diff --git a/src/test/java/org/redisson/RedissonSetTest.java b/src/test/java/org/redisson/RedissonSetTest.java index cd410d973..c0d0748b4 100644 --- a/src/test/java/org/redisson/RedissonSetTest.java +++ b/src/test/java/org/redisson/RedissonSetTest.java @@ -20,6 +20,29 @@ import org.redisson.core.RSortedSet; public class RedissonSetTest extends BaseTest { + public static class SimpleBean { + + private Long lng; + + public Long getLng() { + return lng; + } + + public void setLng(Long lng) { + this.lng = lng; + } + + } + + @Test + public void testAddBean() throws InterruptedException, ExecutionException { + SimpleBean sb = new SimpleBean(); + sb.setLng(1L); + RSet set = redisson.getSet("simple"); + set.add(sb); + Assert.assertEquals(sb.getLng(), set.iterator().next().getLng()); + } + @Test public void testAddAsync() throws InterruptedException, ExecutionException { RSet set = redisson.getSet("simple"); @@ -42,12 +65,12 @@ public class RedissonSetTest extends BaseTest { Assert.assertFalse(set.removeAsync(1).get()); Assert.assertThat(set, Matchers.containsInAnyOrder(3, 7)); - + set.removeAsync(3).get(); Assert.assertFalse(set.contains(3)); Assert.assertThat(set, Matchers.contains(7)); } - + @Test public void testIteratorRemove() { Set list = redisson.getSet("list"); @@ -78,7 +101,7 @@ public class RedissonSetTest extends BaseTest { Assert.assertEquals(0, list.size()); Assert.assertTrue(list.isEmpty()); } - + @Test public void testIteratorSequence() { Set set = redisson.getSet("set"); @@ -90,7 +113,7 @@ public class RedissonSetTest extends BaseTest { for (int i = 0; i < 1000; i++) { setCopy.add(Long.valueOf(i)); } - + checkIterator(set, setCopy); } @@ -104,7 +127,7 @@ public class RedissonSetTest extends BaseTest { Assert.assertEquals(0, setCopy.size()); } - + @Test public void testLong() { Set set = redisson.getSet("set");