程序包 com.sie.mbm.mom.framework.mq.async.redis.config

类 RedisMessageHandlerConfiguration

java.lang.Object

com.sie.mbm.mom.framework.mq.async.redis.config.RedisMessageHandlerConfiguration

@Import(RedisMessageConfigProperties.class)
@AutoConfigureAfter(BasicConfiguration.class)
@ConditionalOnProperty(prefix="mom.message",
                       name="type",
                       havingValue="redis",
                       matchIfMissing=true)
public class RedisMessageHandlerConfiguration
extends Object

消费容器

嵌套类概要

嵌套类

修饰符和类型	类	说明
(专用程序包) static class	RedisMessageHandlerConfiguration.StartStreamMessageListenerContainer	启动监听容器, Spring容器启动就会触发

构造器概要

构造器

构造器	说明
RedisMessageHandlerConfiguration()

方法概要

修饰符和类型	方法	说明
MessageSenderService	messageSenderService(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate, RedisMessageConfigProperties redisMessageConfigProperties)	发送消息实现类
MessageSubscriptionService	messageSubscriptionService(org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>> container, org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate, RedisMessageHelper redisMessageHelper)
RedisMessageScheduled	redisMessageScheduled(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate, MessageSubscriptionService messageSubscriptionService, RedisMessageHelper redisMessageHelper)	定时消息补偿
List<org.springframework.data.redis.stream.Subscription>	redisStreamSubscriptions(List<MessageHandlerInfo> messageHandlerInfos, MessageSubscriptionService messageSubscriptionService)
RedisMessageHelper	redisTaskHelper(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate, RedisMessageConfigProperties redisMessageConfigProperties)	执行工具
org.springframework.context.SmartLifecycle	startStreamMessageListenerContainer(org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>> container)
org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>>	streamMessageListenerContainer(org.springframework.data.redis.connection.RedisConnectionFactory redisConnectionFactory, org.springframework.core.task.AsyncTaskExecutor defaultAsyncExecutor)	创建监听容器, StreamMessageListenerContainer继承SmartLifecycle会自动执行Spring生命周期

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

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

构造器详细资料

RedisMessageHandlerConfiguration

public RedisMessageHandlerConfiguration()

方法详细资料

messageSenderService

@Bean
public MessageSenderService messageSenderService(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate,
 RedisMessageConfigProperties redisMessageConfigProperties)

发送消息实现类

返回:

messageSubscriptionService

@Bean
public MessageSubscriptionService messageSubscriptionService(org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>> container,
 org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate,
 RedisMessageHelper redisMessageHelper)

redisTaskHelper

@Bean
public RedisMessageHelper redisTaskHelper(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate,
 RedisMessageConfigProperties redisMessageConfigProperties)

执行工具

返回:

redisMessageScheduled

@Bean
@ConditionalOnBean(value=MessageHandlerInfo.class,
                   parameterizedContainer=java.util.List.class)
@ConditionalOnProperty(prefix="mom.message",
                       name="enable",
                       havingValue="true",
                       matchIfMissing=true)
public RedisMessageScheduled redisMessageScheduled(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate,
 MessageSubscriptionService messageSubscriptionService,
 RedisMessageHelper redisMessageHelper)

定时消息补偿

返回:

streamMessageListenerContainer

@Bean
public org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>> streamMessageListenerContainer(org.springframework.data.redis.connection.RedisConnectionFactory redisConnectionFactory,
 org.springframework.core.task.AsyncTaskExecutor defaultAsyncExecutor)

创建监听容器, StreamMessageListenerContainer继承SmartLifecycle会自动执行Spring生命周期

参数:

redisConnectionFactory -

defaultAsyncExecutor -

返回:

redisStreamSubscriptions

@Bean
@ConditionalOnBean(value=MessageHandlerInfo.class,
                   parameterizedContainer=java.util.List.class)
public List<org.springframework.data.redis.stream.Subscription> redisStreamSubscriptions(List<MessageHandlerInfo> messageHandlerInfos,
 MessageSubscriptionService messageSubscriptionService)

startStreamMessageListenerContainer

@Bean
@ConditionalOnProperty(prefix="mom.message",
                       name="enable",
                       havingValue="true",
                       matchIfMissing=true)
public org.springframework.context.SmartLifecycle startStreamMessageListenerContainer(org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>> container)