Merge branch 'master' of github.com:xetorthio/jedis
This commit is contained in:
@@ -1095,7 +1095,12 @@ public class BinaryClient extends Connection {
|
|||||||
sendCommand(RESTORE, key, toByteArray(ttl), serializedValue);
|
sendCommand(RESTORE, key, toByteArray(ttl), serializedValue);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Deprecated
|
||||||
public void pexpire(final byte[] key, final int milliseconds) {
|
public void pexpire(final byte[] key, final int milliseconds) {
|
||||||
|
pexpire(key, (long) milliseconds);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void pexpire(final byte[] key, final long milliseconds) {
|
||||||
sendCommand(PEXPIRE, key, toByteArray(milliseconds));
|
sendCommand(PEXPIRE, key, toByteArray(milliseconds));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -3324,7 +3324,12 @@ public class BinaryJedis implements BasicCommands, BinaryJedisCommands,
|
|||||||
return client.getStatusCodeReply();
|
return client.getStatusCodeReply();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Deprecated
|
||||||
public Long pexpire(final byte[] key, final int milliseconds) {
|
public Long pexpire(final byte[] key, final int milliseconds) {
|
||||||
|
return pexpire(key, (long) milliseconds);
|
||||||
|
}
|
||||||
|
|
||||||
|
public Long pexpire(final byte[] key, final long milliseconds) {
|
||||||
checkIsInMulti();
|
checkIsInMulti();
|
||||||
client.pexpire(key, milliseconds);
|
client.pexpire(key, milliseconds);
|
||||||
return client.getIntegerReply();
|
return client.getIntegerReply();
|
||||||
|
|||||||
@@ -781,7 +781,12 @@ public class Client extends BinaryClient implements Commands {
|
|||||||
restore(SafeEncoder.encode(key), ttl, serializedValue);
|
restore(SafeEncoder.encode(key), ttl, serializedValue);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Deprecated
|
||||||
public void pexpire(final String key, final int milliseconds) {
|
public void pexpire(final String key, final int milliseconds) {
|
||||||
|
pexpire(key, (long) milliseconds);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void pexpire(final String key, final long milliseconds) {
|
||||||
pexpire(SafeEncoder.encode(key), milliseconds);
|
pexpire(SafeEncoder.encode(key), milliseconds);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -3062,7 +3062,12 @@ public class Jedis extends BinaryJedis implements JedisCommands,
|
|||||||
return client.getStatusCodeReply();
|
return client.getStatusCodeReply();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Deprecated
|
||||||
public Long pexpire(final String key, final int milliseconds) {
|
public Long pexpire(final String key, final int milliseconds) {
|
||||||
|
return pexpire(key, (long) milliseconds);
|
||||||
|
}
|
||||||
|
|
||||||
|
public Long pexpire(final String key, final long milliseconds) {
|
||||||
checkIsInMulti();
|
checkIsInMulti();
|
||||||
client.pexpire(key, milliseconds);
|
client.pexpire(key, milliseconds);
|
||||||
return client.getIntegerReply();
|
return client.getIntegerReply();
|
||||||
|
|||||||
@@ -1098,12 +1098,22 @@ abstract class PipelineBase extends Queable implements BinaryRedisPipeline,
|
|||||||
return getResponse(BuilderFactory.LONG);
|
return getResponse(BuilderFactory.LONG);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Deprecated
|
||||||
public Response<Long> pexpire(String key, int milliseconds) {
|
public Response<Long> pexpire(String key, int milliseconds) {
|
||||||
|
return pexpire(key, (long) milliseconds);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Deprecated
|
||||||
|
public Response<Long> pexpire(byte[] key, int milliseconds) {
|
||||||
|
return pexpire(key, (long) milliseconds);
|
||||||
|
}
|
||||||
|
|
||||||
|
public Response<Long> pexpire(String key, long milliseconds) {
|
||||||
getClient(key).pexpire(key, milliseconds);
|
getClient(key).pexpire(key, milliseconds);
|
||||||
return getResponse(BuilderFactory.LONG);
|
return getResponse(BuilderFactory.LONG);
|
||||||
}
|
}
|
||||||
|
|
||||||
public Response<Long> pexpire(byte[] key, int milliseconds) {
|
public Response<Long> pexpire(byte[] key, long milliseconds) {
|
||||||
getClient(key).pexpire(key, milliseconds);
|
getClient(key).pexpire(key, milliseconds);
|
||||||
return getResponse(BuilderFactory.LONG);
|
return getResponse(BuilderFactory.LONG);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -475,9 +475,16 @@ public class AllKindOfValuesCommandsTest extends JedisCommandTestBase {
|
|||||||
long status = jedis.pexpire("foo", 10000);
|
long status = jedis.pexpire("foo", 10000);
|
||||||
assertEquals(0, status);
|
assertEquals(0, status);
|
||||||
|
|
||||||
jedis.set("foo", "bar");
|
jedis.set("foo1", "bar1");
|
||||||
status = jedis.pexpire("foo", 10000);
|
status = jedis.pexpire("foo1", 10000);
|
||||||
assertEquals(1, status);
|
assertEquals(1, status);
|
||||||
|
|
||||||
|
jedis.set("foo2", "bar2");
|
||||||
|
status = jedis.pexpire("foo2", 200000000000L);
|
||||||
|
assertEquals(1, status);
|
||||||
|
|
||||||
|
long pttl = jedis.pttl("foo2");
|
||||||
|
assertTrue(pttl > 100000000000L);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
|||||||
Reference in New Issue
Block a user