类的使用
com.sie.mbm.mom.framework.mq.async.MessageHandlerInfo

使用MessageHandlerInfo的程序包

程序包	说明
com.sie.mbm.mom.framework.mq
com.sie.mbm.mom.framework.mq.async.redis	Redis实现
com.sie.mbm.mom.framework.mq.async.redis.config
com.sie.mbm.mom.framework.mq.config

com.sie.mbm.mom.framework.mq中MessageHandlerInfo的使用

返回变量类型为MessageHandlerInfo的类型的com.sie.mbm.mom.framework.mq中的方法

修饰符和类型	方法	说明
List<MessageHandlerInfo>	MessageSubscriptionService.getSubscribes()	获取所有订阅配置

参数类型为MessageHandlerInfo的com.sie.mbm.mom.framework.mq中的方法

修饰符和类型	方法	说明
void	MessageSubscriptionService.subscribe(MessageHandlerInfo messageHandlerInfo)	订阅消息

com.sie.mbm.mom.framework.mq.async.redis中MessageHandlerInfo的使用

类型参数类型为MessageHandlerInfo的com.sie.mbm.mom.framework.mq.async.redis中的字段

修饰符和类型	字段	说明
private List<MessageHandlerInfo>	MessageSubscriptionImpl.messageHandlerInfos

返回变量类型为MessageHandlerInfo的类型的com.sie.mbm.mom.framework.mq.async.redis中的方法

修饰符和类型	方法	说明
List<MessageHandlerInfo>	MessageSubscriptionImpl.getSubscribes()	获取所有订阅

参数类型为MessageHandlerInfo的com.sie.mbm.mom.framework.mq.async.redis中的方法

修饰符和类型	方法	说明
private void	RedisMessageHelper.acknowledge(MessageHandlerInfo taskHandlerInfo, String messageId)	确认消费
void	RedisMessageHelper.lockDoTask(MessageHandlerInfo taskHandlerInfo, org.springframework.data.redis.connection.stream.MapRecord<String,String,String> message)	锁处理消息
void	RedisMessageHelper.lockDoTask(MessageHandlerInfo taskHandlerInfo, org.springframework.data.redis.connection.stream.MapRecord<String,String,String> message, org.springframework.data.redis.connection.stream.PendingMessage pendingMessage)	锁处理消息
void	RedisMessageHelper.lockDoTask(MessageHandlerInfo taskHandlerInfo, org.springframework.data.redis.connection.stream.PendingMessage pendingMessage)	锁处理消息
void	RedisMessageHelper.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)
private void	MessageSubscriptionImpl.registerSubscription(org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>> container, MessageHandlerInfo messageHandlerInfo, RedisMessageHelper redisMessageHelper, int consumeThreadIndex)
void	RedisMessageScheduled.startRetry(MessageHandlerInfo messageHandlerInfo)
void	RedisMessageScheduled.startRetryPendingMessage(MessageHandlerInfo taskHandlerInfo, List<org.springframework.data.redis.connection.stream.PendingMessage> pendingMessages)
void	MessageSubscriptionImpl.subscribe(MessageHandlerInfo messageHandlerInfo)	订阅

com.sie.mbm.mom.framework.mq.async.redis.config中MessageHandlerInfo的使用

类型变量类型为MessageHandlerInfo的com.sie.mbm.mom.framework.mq.async.redis.config中的方法参数

修饰符和类型	方法	说明
List<org.springframework.data.redis.stream.Subscription>	RedisMessageHandlerConfiguration.redisStreamSubscriptions(List<MessageHandlerInfo> messageHandlerInfos, MessageSubscriptionService messageSubscriptionService)

com.sie.mbm.mom.framework.mq.config中MessageHandlerInfo的使用

返回变量类型为MessageHandlerInfo的类型的com.sie.mbm.mom.framework.mq.config中的方法

修饰符和类型	方法	说明
List<MessageHandlerInfo>	BasicConfiguration.messageHandlerInfos(List<MessageHandlerInterface<?>> handlers, ApplicationBizHandle applicationBizHandle)	获取所有消息处理器