程序包 com.sie.mbm.mom.framework.websocket.config

类 RedisMessageDistributorConfiguration

java.lang.Object

com.sie.mbm.mom.framework.websocket.config.RedisMessageDistributorConfiguration

@ConditionalOnClass(org.springframework.data.redis.core.StringRedisTemplate.class)
@ConditionalOnProperty(prefix="mom.websocket",
                       name="message-distributor",
                       havingValue="redis",
                       matchIfMissing=true)
@Configuration(proxyBeanMethods=false)
public class RedisMessageDistributorConfiguration
extends Object

基于 Redis Pub/Sub 的消息分发器

嵌套类概要

嵌套类

修饰符和类型	类	说明
(专用程序包) static class	RedisMessageDistributorConfiguration.RedisMessageListenerRegisterConfiguration

构造器概要

构造器

构造器	说明
RedisMessageDistributorConfiguration()

方法概要

修饰符和类型	方法	说明
RedisMessageDistributor	messageDistributor(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate)
org.springframework.data.redis.listener.RedisMessageListenerContainer	redisMessageListenerContainer(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
RedisWebsocketMessageListener	redisWebsocketMessageListener(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

RedisMessageDistributorConfiguration

public RedisMessageDistributorConfiguration()

方法详细资料

messageDistributor

@Bean
@ConditionalOnMissingBean(MessageDistributor.class)
public RedisMessageDistributor messageDistributor(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate)

redisWebsocketMessageListener

@Bean
@ConditionalOnBean(RedisMessageDistributor.class)
@ConditionalOnMissingBean
public RedisWebsocketMessageListener redisWebsocketMessageListener(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate)

redisMessageListenerContainer

@Bean
@ConditionalOnBean(RedisMessageDistributor.class)
@ConditionalOnMissingBean
public org.springframework.data.redis.listener.RedisMessageListenerContainer redisMessageListenerContainer(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)