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

类 RedisMessageScheduled

java.lang.Object

com.sie.mbm.mom.framework.mq.async.redis.RedisMessageScheduled

public class RedisMessageScheduled
extends Object

消费方pending补偿机制

字段概要

字段

修饰符和类型	字段	说明
private static final long	BASE_RETRY_DELAY_MS	基础重试间隔（1000毫秒）
private final Map<String,Future<?>>	futureMap	存储消息执行结果, 用于限制一个消费组只有一个重试线程
private final MessageSubscriptionService	messageSubscriptionService
private final RedisMessageHelper	redisTaskHelper
private final org.springframework.data.redis.core.StringRedisTemplate	stringRedisTemplate

构造器概要

构造器

构造器	说明
RedisMessageScheduled()

方法概要

修饰符和类型	方法	说明
void	startRetry()
void	startRetry(MessageHandlerInfo messageHandlerInfo)
void	startRetryPendingMessage(MessageHandlerInfo taskHandlerInfo, List<org.springframework.data.redis.connection.stream.PendingMessage> pendingMessages)

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

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

字段详细资料

stringRedisTemplate

private final org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate

messageSubscriptionService

private final MessageSubscriptionService messageSubscriptionService

redisTaskHelper

private final RedisMessageHelper redisTaskHelper

BASE_RETRY_DELAY_MS

private static final long BASE_RETRY_DELAY_MS

基础重试间隔（1000毫秒）

另请参阅:

• 常量字段值

futureMap

private final Map<String,Future<?>> futureMap

存储消息执行结果, 用于限制一个消费组只有一个重试线程

构造器详细资料

RedisMessageScheduled

public RedisMessageScheduled()

方法详细资料

startRetry

@Scheduled(fixedDelay=60000L)
public void startRetry()

startRetry

public void startRetry(MessageHandlerInfo messageHandlerInfo)

startRetryPendingMessage

public void startRetryPendingMessage(MessageHandlerInfo taskHandlerInfo,
 List<org.springframework.data.redis.connection.stream.PendingMessage> pendingMessages)