redis.clients.jedis.Jedis.checkIsInMultiOrPipeline()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(4.7k)|赞(0)|评价(0)|浏览(394)

本文整理了Java中redis.clients.jedis.Jedis.checkIsInMultiOrPipeline()方法的一些代码示例,展示了Jedis.checkIsInMultiOrPipeline()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Jedis.checkIsInMultiOrPipeline()方法的具体详情如下:
包路径:redis.clients.jedis.Jedis
类名称:Jedis
方法名:checkIsInMultiOrPipeline

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);
}

相关文章

Jedis类方法