本文整理了Java中org.springframework.data.redis.core.RedisTemplate.boundSetOps
方法的一些代码示例,展示了RedisTemplate.boundSetOps
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedisTemplate.boundSetOps
方法的具体详情如下:
包路径:org.springframework.data.redis.core.RedisTemplate
类名称: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);
}
}
内容来源于网络,如有侵权,请联系作者删除!