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

类 RedisMessageHelper

java.lang.Object

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

public class RedisMessageHelper
extends Object

嵌套类概要

嵌套类

修饰符和类型	类	说明
private static class	RedisMessageHelper.MessageWrapper

字段概要

字段

修饰符和类型	字段	说明
private RedisMessageHelper	currentMessageHelper
private final RedisMessageConfigProperties	redisMessageConfigProperties
private final org.springframework.data.redis.core.StringRedisTemplate	stringRedisTemplate

构造器概要

构造器

构造器	说明
RedisMessageHelper()

方法概要

修饰符和类型	方法	说明
private void	acknowledge(MessageHandlerInfo taskHandlerInfo, String messageId)	确认消费
private org.springframework.data.redis.connection.stream.MapRecord<String,String,String>	claimMsg(String streamKey, String groupName, String consumerName, org.springframework.data.redis.connection.stream.RecordId recordId, long retryCount)	claim消息
void	lockDoTask(MessageHandlerInfo taskHandlerInfo, org.springframework.data.redis.connection.stream.MapRecord<String,String,String> message)	锁处理消息
void	lockDoTask(MessageHandlerInfo taskHandlerInfo, org.springframework.data.redis.connection.stream.MapRecord<String,String,String> message, org.springframework.data.redis.connection.stream.PendingMessage pendingMessage)	锁处理消息
void	lockDoTask(MessageHandlerInfo taskHandlerInfo, org.springframework.data.redis.connection.stream.PendingMessage pendingMessage)	锁处理消息
void	lockDoTask(RedisMessageHelper.MessageWrapper messageWrapper, MessageHandlerInfo taskHandlerInfo, org.springframework.data.redis.connection.stream.MapRecord<String,String,String> message, org.springframework.data.redis.connection.stream.PendingMessage pendingMessage, long deliveryCount)

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

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

字段详细资料

stringRedisTemplate

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

redisMessageConfigProperties

private final RedisMessageConfigProperties redisMessageConfigProperties

currentMessageHelper

private RedisMessageHelper currentMessageHelper

构造器详细资料

RedisMessageHelper

public RedisMessageHelper()

方法详细资料

lockDoTask

public void lockDoTask(MessageHandlerInfo taskHandlerInfo,
 org.springframework.data.redis.connection.stream.MapRecord<String,String,String> message)

锁处理消息

参数:

taskHandlerInfo - 消息处理器信息

message - 消息

lockDoTask

public void lockDoTask(MessageHandlerInfo taskHandlerInfo,
 org.springframework.data.redis.connection.stream.PendingMessage pendingMessage)

锁处理消息

参数:

taskHandlerInfo - 消息处理器信息

pendingMessage - 消息

lockDoTask

public void lockDoTask(MessageHandlerInfo taskHandlerInfo,
 org.springframework.data.redis.connection.stream.MapRecord<String,String,String> message,
 org.springframework.data.redis.connection.stream.PendingMessage pendingMessage)

锁处理消息

参数:

taskHandlerInfo - 消息处理器信息

message - 消息

pendingMessage - pending消息

lockDoTask

@Lock(value="mq:{messageWrapper.topic}:{messageWrapper.group}:{messageWrapper.messageId}",
      tryLock=false,
      leaseTime=60L,
      failMessage="mq \u6d88\u8d39\u5e42\u7b49, \u9501\u51b2\u7a81\u8df3\u8fc7")
public void lockDoTask(RedisMessageHelper.MessageWrapper messageWrapper,
 MessageHandlerInfo taskHandlerInfo,
 org.springframework.data.redis.connection.stream.MapRecord<String,String,String> message,
 org.springframework.data.redis.connection.stream.PendingMessage pendingMessage,
 long deliveryCount)

acknowledge

private void acknowledge(MessageHandlerInfo taskHandlerInfo,
 String messageId)

确认消费

参数:

taskHandlerInfo - key

messageId - 消息id

claimMsg

private org.springframework.data.redis.connection.stream.MapRecord<String,String,String> claimMsg(String streamKey,
 String groupName,
 String consumerName,
 org.springframework.data.redis.connection.stream.RecordId recordId,
 long retryCount)

claim消息

参数:

streamKey - key

groupName - 组

consumerName - 消费者

recordId - 消息id

返回:

消息详情