本文整理了Java中redis.clients.jedis.Jedis.checkIsInMultiOrPipeline()
方法的一些代码示例,展示了Jedis.checkIsInMultiOrPipeline()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Jedis.checkIsInMultiOrPipeline()
方法的具体详情如下:
包路径:redis.clients.jedis.Jedis
类名称:Jedis
方法名:checkIsInMultiOrPipeline
暂无
代码示例来源:origin: sohutv/cachecloud
@Override
public Long zadd(final String key, final double score, final String member,
final ZAddParams params) {
checkIsInMultiOrPipeline();
client.zadd(key, score, member, params);
return client.getIntegerReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public Set<Tuple> zrevrangeWithScores(final String key, final long start, final long end) {
checkIsInMultiOrPipeline();
client.zrevrangeWithScores(key, start, end);
return getTupledSet();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public Long zlexcount(final String key, final String min, final String max) {
checkIsInMultiOrPipeline();
client.zlexcount(key, min, max);
return client.getIntegerReply();
}
代码示例来源:origin: sohutv/cachecloud
public String clientSetname(final String name) {
checkIsInMultiOrPipeline();
client.clientSetname(name);
return client.getStatusCodeReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public String clusterReset(final Reset resetType) {
checkIsInMultiOrPipeline();
client.clusterReset(resetType);
return client.getStatusCodeReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public String clusterSetSlotNode(final int slot, final String nodeId) {
checkIsInMultiOrPipeline();
client.clusterSetSlotNode(slot, nodeId);
return client.getStatusCodeReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public String clusterSetSlotMigrating(final int slot, final String nodeId) {
checkIsInMultiOrPipeline();
client.clusterSetSlotMigrating(slot, nodeId);
return client.getStatusCodeReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public String clusterForget(final String nodeId) {
checkIsInMultiOrPipeline();
client.clusterForget(nodeId);
return client.getStatusCodeReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public Long clusterKeySlot(final String key) {
checkIsInMultiOrPipeline();
client.clusterKeySlot(key);
return client.getIntegerReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public List<Object> clusterSlots() {
checkIsInMultiOrPipeline();
client.clusterSlots();
return client.getObjectMultiBulkReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public Long geoadd(String key, Map<String, GeoCoordinate> memberCoordinateMap) {
checkIsInMultiOrPipeline();
client.geoadd(key, memberCoordinateMap);
return client.getIntegerReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public String clusterDelSlots(final int... slots) {
checkIsInMultiOrPipeline();
client.clusterDelSlots(slots);
return client.getStatusCodeReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public Long geoadd(String key, double longitude, double latitude, String member) {
checkIsInMultiOrPipeline();
client.geoadd(key, longitude, latitude, member);
return client.getIntegerReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public List<String> geohash(String key, String... members) {
checkIsInMultiOrPipeline();
client.geohash(key, members);
return client.getMultiBulkReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public Set<String> zrevrangeByScore(final String key, final String max, final String min) {
checkIsInMultiOrPipeline();
client.zrevrangeByScore(key, max, min);
final List<String> members = client.getMultiBulkReply();
if (members == null) {
return null;
}
return SetFromList.of(members);
}
代码示例来源:origin: sohutv/cachecloud
@Override
public Long publish(final String channel, final String message) {
checkIsInMultiOrPipeline();
connect();
client.publish(channel, message);
return client.getIntegerReply();
}
代码示例来源:origin: sohutv/cachecloud
@Override
public void psubscribe(final JedisPubSub jedisPubSub, final String... patterns) {
checkIsInMultiOrPipeline();
client.setTimeoutInfinite();
try {
jedisPubSub.proceedWithPatterns(client, patterns);
} finally {
client.rollbackTimeout();
}
}
代码示例来源:origin: sohutv/cachecloud
public Map<String, String> pubsubNumSub(String... channels) {
checkIsInMultiOrPipeline();
client.pubsubNumSub(channels);
return BuilderFactory.PUBSUB_NUMSUB_MAP.build(client.getBinaryMultiBulkReply());
}
代码示例来源:origin: sohutv/cachecloud
@Override
public Set<String> zrevrange(final String key, final long start, final long end) {
checkIsInMultiOrPipeline();
client.zrevrange(key, start, end);
final List<String> members = client.getMultiBulkReply();
if (members == null) {
return null;
}
return SetFromList.of(members);
}
代码示例来源:origin: sohutv/cachecloud
@Override
public Set<String> zrevrangeByLex(String key, String max, String min, int offset, int count) {
checkIsInMultiOrPipeline();
client.zrevrangeByLex(key, max, min, offset, count);
final List<String> members = client.getMultiBulkReply();
if (members == null) {
return null;
}
return SetFromList.of(members);
}
内容来源于网络,如有侵权,请联系作者删除!