接口的使用
com.sie.mbm.mom.framework.mq.MessageSubscriptionService
程序包
说明
Redis实现
-
com.sie.mbm.mom.framework.mq.async.redis中MessageSubscriptionService的使用
修饰符和类型字段说明private final MessageSubscriptionServiceRedisMessageScheduled.messageSubscriptionService -
com.sie.mbm.mom.framework.mq.async.redis.config中MessageSubscriptionService的使用
修饰符和类型方法说明RedisMessageHandlerConfiguration.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) 修饰符和类型方法说明RedisMessageHandlerConfiguration.redisMessageScheduled(org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate, MessageSubscriptionService messageSubscriptionService, RedisMessageHelper redisMessageHelper) 定时消息补偿List<org.springframework.data.redis.stream.Subscription> RedisMessageHandlerConfiguration.redisStreamSubscriptions(List<MessageHandlerInfo> messageHandlerInfos, MessageSubscriptionService messageSubscriptionService)