cn.springlet.rocketmq.consumer

接口 BaseMessageListenerHandler<T>

public interface BaseMessageListenerHandler<T>

消息业务 各服务实现此类 分发业务消息

作者:

springlet

方法概要

限定符和类型	方法和说明
void	businessOpt(T msgKeyEnum, com.aliyun.openservices.ons.api.Message message) 具体 tag 的业务操作
default <B> B	getBodyObj(MsgKeyEnum msgKeyEnum, com.aliyun.openservices.ons.api.Message message, Class<B> clazz) 获取 消息参数对象
Class<T>	getMsgKeyEnumClass() 获取业务类型

方法详细资料

businessOpt

void businessOpt(T msgKeyEnum,
                 com.aliyun.openservices.ons.api.Message message)

具体 tag 的业务操作

参数:

message -

getMsgKeyEnumClass

Class<T> getMsgKeyEnumClass()

获取业务类型

getBodyObj

default <B> B getBodyObj(MsgKeyEnum msgKeyEnum,
                         com.aliyun.openservices.ons.api.Message message,
                         Class<B> clazz)

获取 消息参数对象

类型参数:

B -

参数:

message -

clazz -

返回: