本文整理汇总了Java中org.springframework.data.redis.listener.PatternTopic类的典型用法代码示例。如果您正苦于以下问题:Java PatternTopic类的具体用法?Java PatternTopic怎么用?Java PatternTopic使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
PatternTopic类属于org.springframework.data.redis.listener包,在下文中一共展示了PatternTopic类的5个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: redisMessageListenerContainer
import org.springframework.data.redis.listener.PatternTopic; //导入依赖的package包/类
@Bean
public RedisMessageListenerContainer redisMessageListenerContainer() {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(this.redisConnectionFactory);
if (this.redisTaskExecutor != null) {
container.setTaskExecutor(this.redisTaskExecutor);
}
if (this.redisSubscriptionExecutor != null) {
container.setSubscriptionExecutor(this.redisSubscriptionExecutor);
}
container.addMessageListener(sessionRepository(),
Arrays.asList(new PatternTopic("[email protected]*:del"),
new PatternTopic("[email protected]*:expired")));
container.addMessageListener(sessionRepository(),
Collections.singletonList(new PatternTopic(
sessionRepository().getSessionCreatedChannelPrefix() + "*")));
return container;
}
开发者ID:spring-projects,项目名称:spring-session,代码行数:19,代码来源:RedisHttpSessionConfiguration.java
示例2: redisMessageListenerContainer
import org.springframework.data.redis.listener.PatternTopic; //导入依赖的package包/类
@Bean
public RedisMessageListenerContainer redisMessageListenerContainer(
RedisConnectionFactory connectionFactory,
MessageListenerAdapter listenerAdapter) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.addMessageListener(listenerAdapter, new PatternTopic("__key*__:*"));
return container;
}
开发者ID:joelchartier,项目名称:slackbot-pomodoro,代码行数:12,代码来源:RedisListenerConfiguration.java
示例3: toTopics
import org.springframework.data.redis.listener.PatternTopic; //导入依赖的package包/类
private Collection<Topic> toTopics(String channels) {
String[] channelsArrays = channels.split(",");
List<Topic> topics = new ArrayList<>();
for (String channel : channelsArrays) {
String name = channel.trim();
if (Command.PSUBSCRIBE.equals(redisConfiguration.getCommand())) {
topics.add(new PatternTopic(name));
} else if (Command.SUBSCRIBE.equals(redisConfiguration.getCommand())) {
topics.add(new ChannelTopic(name));
} else {
throw new IllegalArgumentException("Unsupported Command " + redisConfiguration.getCommand());
}
}
return topics;
}
开发者ID:HydAu,项目名称:Camel,代码行数:16,代码来源:RedisConsumer.java
示例4: registerExpiredEventListener
import org.springframework.data.redis.listener.PatternTopic; //导入依赖的package包/类
@PostConstruct
private void registerExpiredEventListener() {
expiredListener = new MessageListener() {
@Override
public void onMessage(Message message, byte[] pattern) {
byte[] body = message.getBody();
if (body == null) {
return;
}
String key;
try {
key = new String(message.getBody(), "UTF-8");
} catch (UnsupportedEncodingException e) {
LOGGER.debug(() -> "failed to decode message body: " + bytesToHex(body), e);
return;
}
if (!key.startsWith(PREFIX_EXPIRE)) {
return;
}
String accessToken = key.substring(PREFIX_EXPIRE.length());
template.delete(keyAccessToken(accessToken));
Map<String, String> values = hashOps.entries(keyAccessToken(accessToken));
if (values != null && !values.isEmpty()) {
setOps.remove(keyClientToken(values.get(KEY_CLIENT_TOKEN)), accessToken);
setOps.remove(keyAccount(values.get(KEY_OWNER)), accessToken);
}
}
};
container.addMessageListener(expiredListener, new PatternTopic("[email protected]*__:expired"));
}
开发者ID:to2mbn,项目名称:authlib-agent,代码行数:35,代码来源:TokenRepositoryImpl.java
示例5: RedisTimerMessageListenerContainer
import org.springframework.data.redis.listener.PatternTopic; //导入依赖的package包/类
public RedisTimerMessageListenerContainer(LodsveRedisConnectionFactory connectionFactory, RedisTimerListener listener) {
super.setConnectionFactory(connectionFactory);
super.addMessageListener(listener, new PatternTopic("[email protected]*:expired"));
}
开发者ID:lodsve,项目名称:lodsve-framework,代码行数:5,代码来源:RedisTimerMessageListenerContainer.java
注:本文中的org.springframework.data.redis.listener.PatternTopic类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论