rocketmq-spring
rocketmq-spring copied to clipboard
Bug DefaultRocketMQListenerContainer类处理泛型时,存在问题
声明一个抽象类EnhanceMessageHandler实现RocketMQListener接口
abstract class EnhanceMessageHandler<T extends BaseMessage> implements RocketMQListener<T>{}
声明一个类实现MchApplymentConsumer extends EnhanceMessageHandler<MchApplymentMessage>实现抽象类EnhanceMessageHandler
DefaultRocketMQListenerContainer的getMessageType返回的Type类型为T
可以继承RocketMQListener<MessageExt>
可以继承RocketMQListener<MessageExt>
我们现在要在RocketMQListener基础上在封装一个抽象基础类
public abstract class MessageHandler<T> implements RocketMQListener<MessageExt> {
@Override
public void onMessage(MessageExt messageExt) {
// 重写消费逻辑
}
}
public abstract class MessageHandler<T> implements RocketMQListener<MessageExt> { @Override public void onMessage(MessageExt messageExt) { // 重写消费逻辑 } }
你试过了吗,这样可以用?