org.springframework.data.redis.core.RedisTemplate.boundSetOps()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(2.9k)|赞(0)|评价(0)|浏览(123)

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

RedisTemplate.boundSetOps介绍

暂无

代码示例

代码示例来源:origin: spring-projects/spring-integration

@SuppressWarnings("unchecked")
private void writeToSet(final RedisSet<Object> set, Message<?> message) {
  final Object payload = message.getPayload();
  if (this.extractPayloadElements && payload instanceof Collection<?>) {
    BoundSetOperations<String, Object> ops =
        (BoundSetOperations<String, Object>) this.redisTemplate.boundSetOps(set.getKey());
    processInPipeline(() -> {
      for (Object object : ((Collection<?>) payload)) {
        ops.add(object);
      }
    });
  }
  else {
    set.add(payload);
  }
}

代码示例来源:origin: spring-projects/spring-xd-samples

private Set<String> getUserNavigationHistory(String user) {
  Set<String> userHistory = usersNavigatedItems.get(user);
  if (userHistory == null) {
    userHistory = redisTemplate.boundSetOps(buildKey(user)).members();
    if (userHistory == null) {
      userHistory = new HashSet<String>();
    }
    usersNavigatedItems.put(user, userHistory);
  }
  return userHistory;
}

代码示例来源:origin: davidmarquis/redisq

public Collection<String> getRegisteredConsumers(String queueName) {
  BoundSetOperations<String, String> ops = redisTemplate.boundSetOps(keyForRegisteredConsumers(queueName));
  return ops.members();
}

代码示例来源:origin: zuihou/zuihou-admin-cloud

protected BoundSetOperations<K, V> getBoundSetOperations() {
  return super.getRedisTemplate().boundSetOps(key());
}

代码示例来源:origin: davidmarquis/redisq

public void ensureConsumerRegistered(String queueName, String consumerId) {
  BoundSetOperations<String, String> ops = redisTemplate.boundSetOps(keyForRegisteredConsumers(queueName));
  ops.add(consumerId);
}

代码示例来源:origin: davidmarquis/redisq

public String randomPopFromSet(String queueName, String consumerId) {
  String key = keyForConsumerSpecificQueue(queueName, consumerId);
  BoundSetOperations<String, String> ops = redisTemplate.boundSetOps(key);
  return ops.pop();
}

代码示例来源:origin: spring-projects/spring-xd-samples

private void addProductToHistory(String user, String product) {
  Set<String> userHistory = getUserNavigationHistory(user);
  userHistory.add(product);
  redisTemplate.boundSetOps(buildKey(user)).add(product);
}

代码示例来源:origin: org.springframework.integration/spring-integration-redis

@SuppressWarnings("unchecked")
private void writeToSet(final RedisSet<Object> set, Message<?> message) {
  final Object payload = message.getPayload();
  if (this.extractPayloadElements && payload instanceof Collection<?>) {
    BoundSetOperations<String, Object> ops =
        (BoundSetOperations<String, Object>) this.redisTemplate.boundSetOps(set.getKey());
    processInPipeline(() -> {
      for (Object object : ((Collection<?>) payload)) {
        ops.add(object);
      }
    });
  }
  else {
    set.add(payload);
  }
}

相关文章

微信公众号

最新文章

更多