diff --git a/src/main/java/redis/clients/jedis/BinaryClient.java b/src/main/java/redis/clients/jedis/BinaryClient.java index e9bd62a..6cf059c 100644 --- a/src/main/java/redis/clients/jedis/BinaryClient.java +++ b/src/main/java/redis/clients/jedis/BinaryClient.java @@ -140,7 +140,7 @@ public class BinaryClient extends Connection { sendCommand(MSETNX, keysvalues); } - public void decrBy(final byte[] key, final int integer) { + public void decrBy(final byte[] key, final long integer) { sendCommand(DECRBY, key, toByteArray(integer)); } @@ -148,7 +148,7 @@ public class BinaryClient extends Connection { sendCommand(DECR, key); } - public void incrBy(final byte[] key, final int integer) { + public void incrBy(final byte[] key, final long integer) { sendCommand(INCRBY, key, toByteArray(integer)); } @@ -194,7 +194,7 @@ public class BinaryClient extends Connection { sendCommand(HMGET, params); } - public void hincrBy(final byte[] key, final byte[] field, final int value) { + public void hincrBy(final byte[] key, final byte[] field, final long value) { sendCommand(HINCRBY, key, field, toByteArray(value)); } diff --git a/src/main/java/redis/clients/jedis/BinaryJedis.java b/src/main/java/redis/clients/jedis/BinaryJedis.java index 0e7e329..09ca04c 100644 --- a/src/main/java/redis/clients/jedis/BinaryJedis.java +++ b/src/main/java/redis/clients/jedis/BinaryJedis.java @@ -520,7 +520,7 @@ public class BinaryJedis implements BinaryJedisCommands { * @return Integer reply, this commands will reply with the new value of key * after the increment. */ - public Long decrBy(final byte[] key, final int integer) { + public Long decrBy(final byte[] key, final long integer) { checkIsInMulti(); client.decrBy(key, integer); return client.getIntegerReply(); @@ -576,7 +576,7 @@ public class BinaryJedis implements BinaryJedisCommands { * @return Integer reply, this commands will reply with the new value of key * after the increment. */ - public Long incrBy(final byte[] key, final int integer) { + public Long incrBy(final byte[] key, final long integer) { checkIsInMulti(); client.incrBy(key, integer); return client.getIntegerReply(); @@ -768,7 +768,7 @@ public class BinaryJedis implements BinaryJedisCommands { * @return Integer reply The new value at field after the increment * operation. */ - public Long hincrBy(final byte[] key, final byte[] field, final int value) { + public Long hincrBy(final byte[] key, final byte[] field, final long value) { checkIsInMulti(); client.hincrBy(key, field, value); return client.getIntegerReply(); diff --git a/src/main/java/redis/clients/jedis/BinaryJedisCommands.java b/src/main/java/redis/clients/jedis/BinaryJedisCommands.java index c38d3b8..241734f 100644 --- a/src/main/java/redis/clients/jedis/BinaryJedisCommands.java +++ b/src/main/java/redis/clients/jedis/BinaryJedisCommands.java @@ -31,11 +31,11 @@ public interface BinaryJedisCommands { String setex(byte[] key, int seconds, byte[] value); - Long decrBy(byte[] key, int integer); + Long decrBy(byte[] key, long integer); Long decr(byte[] key); - Long incrBy(byte[] key, int integer); + Long incrBy(byte[] key, long integer); Long incr(byte[] key); @@ -53,7 +53,7 @@ public interface BinaryJedisCommands { List hmget(byte[] key, byte[]... fields); - Long hincrBy(byte[] key, byte[] field, int value); + Long hincrBy(byte[] key, byte[] field, long value); Boolean hexists(byte[] key, byte[] field); diff --git a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java index 6da4753..1143121 100644 --- a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java +++ b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java @@ -90,7 +90,7 @@ public class BinaryShardedJedis extends Sharded return j.setex(key, seconds, value); } - public Long decrBy(byte[] key, int integer) { + public Long decrBy(byte[] key, long integer) { Jedis j = getShard(key); return j.decrBy(key, integer); } @@ -100,7 +100,7 @@ public class BinaryShardedJedis extends Sharded return j.decr(key); } - public Long incrBy(byte[] key, int integer) { + public Long incrBy(byte[] key, long integer) { Jedis j = getShard(key); return j.incrBy(key, integer); } @@ -145,7 +145,7 @@ public class BinaryShardedJedis extends Sharded return j.hmget(key, fields); } - public Long hincrBy(byte[] key, byte[] field, int value) { + public Long hincrBy(byte[] key, byte[] field, long value) { Jedis j = getShard(key); return j.hincrBy(key, field, value); } diff --git a/src/main/java/redis/clients/jedis/Client.java b/src/main/java/redis/clients/jedis/Client.java index ef76d45..ee52f7b 100644 --- a/src/main/java/redis/clients/jedis/Client.java +++ b/src/main/java/redis/clients/jedis/Client.java @@ -103,7 +103,7 @@ public class Client extends BinaryClient implements Commands { msetnx(bkeysvalues); } - public void decrBy(final String key, final int integer) { + public void decrBy(final String key, final long integer) { decrBy(SafeEncoder.encode(key), integer); } @@ -111,7 +111,7 @@ public class Client extends BinaryClient implements Commands { decr(SafeEncoder.encode(key)); } - public void incrBy(final String key, final int integer) { + public void incrBy(final String key, final long integer) { incrBy(SafeEncoder.encode(key), integer); } @@ -159,7 +159,7 @@ public class Client extends BinaryClient implements Commands { hmget(SafeEncoder.encode(key), bfields); } - public void hincrBy(final String key, final String field, final int value) { + public void hincrBy(final String key, final String field, final long value) { hincrBy(SafeEncoder.encode(key), SafeEncoder.encode(field), value); } diff --git a/src/main/java/redis/clients/jedis/Commands.java b/src/main/java/redis/clients/jedis/Commands.java index 3ece458..63bead0 100644 --- a/src/main/java/redis/clients/jedis/Commands.java +++ b/src/main/java/redis/clients/jedis/Commands.java @@ -42,11 +42,11 @@ public interface Commands { public void msetnx(final String... keysvalues); - public void decrBy(final String key, final int integer); + public void decrBy(final String key, final long integer); public void decr(final String key); - public void incrBy(final String key, final int integer); + public void incrBy(final String key, final long integer); public void incr(final String key); @@ -64,7 +64,7 @@ public interface Commands { public void hmget(final String key, final String... fields); - public void hincrBy(final String key, final String field, final int value); + public void hincrBy(final String key, final String field, final long value); public void hexists(final String key, final String field); diff --git a/src/main/java/redis/clients/jedis/Jedis.java b/src/main/java/redis/clients/jedis/Jedis.java index acb467d..c8ffe5c 100644 --- a/src/main/java/redis/clients/jedis/Jedis.java +++ b/src/main/java/redis/clients/jedis/Jedis.java @@ -518,7 +518,7 @@ public class Jedis extends BinaryJedis implements JedisCommands { * @return Integer reply, this commands will reply with the new value of key * after the increment. */ - public Long decrBy(final String key, final int integer) { + public Long decrBy(final String key, final long integer) { runChecks(); client.decrBy(key, integer); return client.getIntegerReply(); @@ -574,7 +574,7 @@ public class Jedis extends BinaryJedis implements JedisCommands { * @return Integer reply, this commands will reply with the new value of key * after the increment. */ - public Long incrBy(final String key, final int integer) { + public Long incrBy(final String key, final long integer) { runChecks(); client.incrBy(key, integer); return client.getIntegerReply(); @@ -766,7 +766,7 @@ public class Jedis extends BinaryJedis implements JedisCommands { * @return Integer reply The new value at field after the increment * operation. */ - public Long hincrBy(final String key, final String field, final int value) { + public Long hincrBy(final String key, final String field, final long value) { runChecks(); client.hincrBy(key, field, value); return client.getIntegerReply(); diff --git a/src/main/java/redis/clients/jedis/JedisCommands.java b/src/main/java/redis/clients/jedis/JedisCommands.java index f83fa6e..733f1a8 100644 --- a/src/main/java/redis/clients/jedis/JedisCommands.java +++ b/src/main/java/redis/clients/jedis/JedisCommands.java @@ -29,11 +29,11 @@ public interface JedisCommands { String setex(String key, int seconds, String value); - Long decrBy(String key, int integer); + Long decrBy(String key, long integer); Long decr(String key); - Long incrBy(String key, int integer); + Long incrBy(String key, long integer); Long incr(String key); @@ -51,7 +51,7 @@ public interface JedisCommands { List hmget(String key, String... fields); - Long hincrBy(String key, String field, int value); + Long hincrBy(String key, String field, long value); Boolean hexists(String key, String field); diff --git a/src/main/java/redis/clients/jedis/Pipeline.java b/src/main/java/redis/clients/jedis/Pipeline.java index 55266db..514305e 100644 --- a/src/main/java/redis/clients/jedis/Pipeline.java +++ b/src/main/java/redis/clients/jedis/Pipeline.java @@ -28,7 +28,7 @@ public class Pipeline implements Commands { client.decr(key); } - public void decrBy(String key, int integer) { + public void decrBy(String key, long integer) { client.decrBy(key, integer); } @@ -76,7 +76,7 @@ public class Pipeline implements Commands { client.hgetAll(key); } - public void hincrBy(String key, String field, int value) { + public void hincrBy(String key, String field, long value) { client.hincrBy(key, field, value); } @@ -112,7 +112,7 @@ public class Pipeline implements Commands { client.incr(key); } - public void incrBy(String key, int integer) { + public void incrBy(String key, long integer) { client.incrBy(key, integer); } diff --git a/src/main/java/redis/clients/jedis/PipelineBlock.java b/src/main/java/redis/clients/jedis/PipelineBlock.java index 47ae67f..23fe90d 100644 --- a/src/main/java/redis/clients/jedis/PipelineBlock.java +++ b/src/main/java/redis/clients/jedis/PipelineBlock.java @@ -27,7 +27,7 @@ public abstract class PipelineBlock implements Commands { client.decr(key); } - public void decrBy(String key, int integer) { + public void decrBy(String key, long integer) { client.decrBy(key, integer); } @@ -75,7 +75,7 @@ public abstract class PipelineBlock implements Commands { client.hgetAll(key); } - public void hincrBy(String key, String field, int value) { + public void hincrBy(String key, String field, long value) { client.hincrBy(key, field, value); } @@ -111,7 +111,7 @@ public abstract class PipelineBlock implements Commands { client.incr(key); } - public void incrBy(String key, int integer) { + public void incrBy(String key, long integer) { client.incrBy(key, integer); } diff --git a/src/main/java/redis/clients/jedis/ShardedJedis.java b/src/main/java/redis/clients/jedis/ShardedJedis.java index 1645b3b..213f3ed 100644 --- a/src/main/java/redis/clients/jedis/ShardedJedis.java +++ b/src/main/java/redis/clients/jedis/ShardedJedis.java @@ -86,7 +86,7 @@ public class ShardedJedis extends BinaryShardedJedis implements JedisCommands { return j.setex(key, seconds, value); } - public Long decrBy(String key, int integer) { + public Long decrBy(String key, long integer) { Jedis j = getShard(key); return j.decrBy(key, integer); } @@ -96,7 +96,7 @@ public class ShardedJedis extends BinaryShardedJedis implements JedisCommands { return j.decr(key); } - public Long incrBy(String key, int integer) { + public Long incrBy(String key, long integer) { Jedis j = getShard(key); return j.incrBy(key, integer); } @@ -141,7 +141,7 @@ public class ShardedJedis extends BinaryShardedJedis implements JedisCommands { return j.hmget(key, fields); } - public Long hincrBy(String key, String field, int value) { + public Long hincrBy(String key, String field, long value) { Jedis j = getShard(key); return j.hincrBy(key, field, value); }