Impl zpopmin command

pom.xml

@@ -191,6 +191,7 @@
 				    </execution>
 				</executions>		
 			</plugin>
+
 		</plugins>
 	</build>
 </project>

src/main/java/redis/clients/jedis/BinaryClient.java

@@ -503,6 +503,14 @@ public void zscore(final byte[] key, final byte[] member) {
     sendCommand(ZSCORE, key, member);
   }
 
+  public void zpopmin(final byte[] key) {
+    sendCommand(ZPOPMIN, key);
+  }
+
+  public void zpopmin(final byte[] key, final long count) {
+    sendCommand(ZPOPMIN, key, toByteArray(count));
+  }
+
   public void multi() {
     sendCommand(MULTI);
     isInMulti = true;

src/main/java/redis/clients/jedis/BinaryJedis.java

@@ -1841,6 +1841,22 @@ public Double zscore(final byte[] key, final byte[] member) {
     return (score != null ? new Double(score) : null);
   }
 
+
+
+  @Override
+  public Set<Tuple> zpopmin(final byte[] key) {
+    checkIsInMultiOrPipeline();
+    client.zpopmin(key);
+    return getTupledSet();
+  }
+
+  @Override
+  public Set<Tuple> zpopmin(final byte[] key, final long count) {
+    checkIsInMultiOrPipeline();
+    client.zpopmin(key, count);
+    return getTupledSet();
+  }
+
   public Transaction multi() {
     client.multi();
     client.getOne(); // expected OK

src/main/java/redis/clients/jedis/BinaryJedisCluster.java

@@ -906,6 +906,26 @@ public Double execute(Jedis connection) {
     }.runBinary(key);
   }
 
+  @Override
+  public Set<Tuple> zpopmin(final byte[] key, final long count) {
+    return new JedisClusterCommand<Set<Tuple>>(connectionHandler, maxAttempts) {
+      @Override
+      public Set<Tuple> execute(Jedis connection) {
+        return connection.zpopmin(key, count);
+      }
+    }.runBinary(key);
+  }
+
+  @Override
+  public Set<Tuple> zpopmin(final byte[] key) {
+    return new JedisClusterCommand<Set<Tuple>>(connectionHandler, maxAttempts) {
+      @Override
+      public Set<Tuple> execute(Jedis connection) {
+        return connection.zpopmin(key);
+      }
+    }.runBinary(key);
+  }
+
   @Override
   public List<byte[]> sort(final byte[] key) {
     return new JedisClusterCommand<List<byte[]>>(connectionHandler, maxAttempts) {

src/main/java/redis/clients/jedis/BinaryShardedJedis.java

@@ -534,6 +534,18 @@ public Double zscore(final byte[] key, final byte[] member) {
     return j.zscore(key, member);
   }
 
+  @Override
+  public Set<Tuple> zpopmin(final byte[] key) {
+    Jedis j = getShard(key);
+    return j.zpopmin(key);
+  }
+
+  @Override
+  public Set<Tuple> zpopmin(final byte[] key, final long count) {
+    Jedis j = getShard(key);
+    return j.zpopmin(key, count);
+  }
+
   @Override
   public List<byte[]> sort(final byte[] key) {
     Jedis j = getShard(key);

src/main/java/redis/clients/jedis/Client.java

@@ -465,6 +465,16 @@ public void zscore(final String key, final String member) {
     zscore(SafeEncoder.encode(key), SafeEncoder.encode(member));
   }
 
+  @Override
+  public void zpopmin(final String key) {
+    zpopmin(SafeEncoder.encode(key));
+  }
+
+  @Override
+  public void zpopmin(final String key, final long count) {
+    zpopmin(SafeEncoder.encode(key), count);
+  }
+
   @Override
   public void watch(final String... keys) {
     watch(SafeEncoder.encodeMany(keys));

src/main/java/redis/clients/jedis/Jedis.java

@@ -1673,6 +1673,21 @@ public Double zscore(final String key, final String member) {
     return BuilderFactory.DOUBLE.build(client.getOne());
   }
 
+
+  @Override
+  public Set<Tuple> zpopmin(final String key) {
+    checkIsInMultiOrPipeline();
+    client.zpopmin(key);
+    return getTupledSet();
+  }
+
+  @Override
+  public Set<Tuple> zpopmin(final String key, final long count) {
+    checkIsInMultiOrPipeline();
+    client.zpopmin(key, count);
+    return getTupledSet();
+  }
+
   @Override
   public String watch(final String... keys) {
     client.watch(keys);

src/main/java/redis/clients/jedis/PipelineBase.java

@@ -1299,6 +1299,18 @@ public Response<Double> zscore(final byte[] key, final byte[] member) {
     return getResponse(BuilderFactory.DOUBLE);
   }
 
+  @Override
+  public Response<Set<Tuple>> zpopmin(final String key) {
+    getClient(key).zpopmin(key);
+    return getResponse(BuilderFactory.TUPLE_ZSET);
+  }
+
+  @Override
+  public Response<Set<Tuple>> zpopmin(final String key, final long count) {
+    getClient(key).zpopmin(key, count);
+    return getResponse(BuilderFactory.TUPLE_ZSET);
+  }
+
   @Override
   public Response<Long> zlexcount(final byte[] key, final byte[] min, final byte[] max) {
     getClient(key).zlexcount(key, min, max);

src/main/java/redis/clients/jedis/Protocol.java

@@ -249,7 +249,7 @@ public static enum Command implements ProtocolCommand {
     HINCRBY, HEXISTS, HDEL, HLEN, HKEYS, HVALS, HGETALL, RPUSH, LPUSH, LLEN, LRANGE, LTRIM, LINDEX,
     LSET, LREM, LPOP, RPOP, RPOPLPUSH, SADD, SMEMBERS, SREM, SPOP, SMOVE, SCARD, SISMEMBER, SINTER,
     SINTERSTORE, SUNION, SUNIONSTORE, SDIFF, SDIFFSTORE, SRANDMEMBER, ZADD, ZRANGE, ZREM, ZINCRBY,
-    ZRANK, ZREVRANK, ZREVRANGE, ZCARD, ZSCORE, MULTI, DISCARD, EXEC, WATCH, UNWATCH, SORT, BLPOP,
+    ZRANK, ZREVRANK, ZREVRANGE, ZCARD, ZSCORE, ZPOPMIN, MULTI, DISCARD, EXEC, WATCH, UNWATCH, SORT, BLPOP,
     BRPOP, AUTH, SUBSCRIBE, PUBLISH, UNSUBSCRIBE, PSUBSCRIBE, PUNSUBSCRIBE, PUBSUB, ZCOUNT,
     ZRANGEBYSCORE, ZREVRANGEBYSCORE, ZREMRANGEBYRANK, ZREMRANGEBYSCORE, ZUNIONSTORE, ZINTERSTORE,
     ZLEXCOUNT, ZRANGEBYLEX, ZREVRANGEBYLEX, ZREMRANGEBYLEX, SAVE, BGSAVE, BGREWRITEAOF, LASTSAVE,

src/main/java/redis/clients/jedis/ShardedJedis.java

@@ -572,6 +572,18 @@ public Double zscore(final String key, final String member) {
     return j.zscore(key, member);
   }
 
+  @Override
+  public Set<Tuple> zpopmin(final String key) {
+    Jedis j = getShard(key);
+    return j.zpopmin(key);
+  }
+
+  @Override
+  public Set<Tuple> zpopmin(final String key, final long count) {
+    Jedis j = getShard(key);
+    return j.zpopmin(key, count);
+  }
+
   @Override
   public List<String> sort(final String key) {
     Jedis j = getShard(key);

src/main/java/redis/clients/jedis/commands/BinaryJedisClusterCommands.java

@@ -179,6 +179,10 @@ public interface BinaryJedisClusterCommands {
 
   Double zscore(byte[] key, byte[] member);
 
+  Set<Tuple> zpopmin(byte[] key);
+
+  Set<Tuple> zpopmin(byte[] key, long count);
+
   List<byte[]> sort(byte[] key);
 
   List<byte[]> sort(byte[] key, SortingParams sortingParameters);

src/main/java/redis/clients/jedis/commands/BinaryJedisCommands.java

@@ -184,6 +184,10 @@ public interface BinaryJedisCommands {
 
   Double zscore(byte[] key, byte[] member);
 
+  Set<Tuple> zpopmin(byte[] key);
+
+  Set<Tuple> zpopmin(byte[] key, long count);
+
   List<byte[]> sort(byte[] key);
 
   List<byte[]> sort(byte[] key, SortingParams sortingParameters);

src/main/java/redis/clients/jedis/commands/Commands.java

@@ -197,6 +197,10 @@ public interface Commands {
 
   void zscore(String key, String member);
 
+  void zpopmin(String key);
+
+  void zpopmin(String key, long count);
+
   void watch(String... keys);
 
   void sort(String key);

src/main/java/redis/clients/jedis/commands/JedisCommands.java

@@ -187,6 +187,10 @@ public interface JedisCommands {
 
   Double zscore(String key, String member);
 
+  Set<Tuple> zpopmin(String key);
+
+  Set<Tuple> zpopmin(String key, long count);
+
   List<String> sort(String key);
 
   List<String> sort(String key, SortingParams sortingParameters);

src/main/java/redis/clients/jedis/commands/RedisPipeline.java

@@ -228,6 +228,10 @@ Response<Set<Tuple>> zrevrangeByScoreWithScores(String key, String max, String m
 
   Response<Double> zscore(String key, String member);
 
+  Response<Set<Tuple>> zpopmin(String key);
+
+  Response<Set<Tuple>> zpopmin(String key, long count);
+
   Response<Long> zlexcount(String key, String min, String max);
 
   Response<Set<String>> zrangeByLex(String key, String min, String max);

src/test/java/redis/clients/jedis/tests/commands/SortedSetCommandsTest.java

@@ -544,6 +544,55 @@ public void zscore() {
   }
 
   @Test
+  public void zpopmin() {
+
+    jedis.zadd("foo", 1d, "a",ZAddParams.zAddParams().nx());
+    jedis.zadd("foo", 10d, "b",ZAddParams.zAddParams().nx());
+    jedis.zadd("foo", 0.1d, "c",ZAddParams.zAddParams().nx());
+    jedis.zadd("foo", 2d, "a",ZAddParams.zAddParams().nx());
+
+    Set<Tuple> range = jedis.zpopmin("foo",  2);
+
+    Set<Tuple> expected = new LinkedHashSet<Tuple>();
+    expected.add(new Tuple("c", 0.1d));
+    expected.add(new Tuple("a", 1d));
+
+    assertEquals(expected, range);
+
+
+    range = jedis.zpopmin("foo");
+
+    expected = new LinkedHashSet<Tuple>();
+    expected.add(new Tuple("b", 10d));
+
+    assertEquals(expected, range);
+
+
+
+    // Binary
+
+    jedis.zadd(bfoo, 1d, ba);
+    jedis.zadd(bfoo, 10d, bb);
+    jedis.zadd(bfoo, 0.1d, bc);
+    jedis.zadd(bfoo, 2d, ba);
+
+    Set<Tuple> brange = jedis.zpopmin(bfoo, 2);
+
+    Set<Tuple> bexpected = new LinkedHashSet<Tuple>();
+    bexpected.add(new Tuple(bc, 0.1d));
+    bexpected.add(new Tuple(ba, 2d));
+
+    assertEquals(bexpected, brange);
+
+    brange = jedis.zpopmin(bfoo);
+
+    bexpected = new LinkedHashSet<Tuple>();
+    bexpected.add(new Tuple(bb, 10d));
+
+    assertEquals(bexpected, brange);
+  }
+
+    @Test
   public void zcount() {
     jedis.zadd("foo", 1d, "a");
     jedis.zadd("foo", 10d, "b");