rocketmq-spring icon indicating copy to clipboard operation
rocketmq-spring copied to clipboard

Bug DefaultRocketMQListenerContainer类处理泛型时,存在问题

Open xuziyang opened this issue 11 months ago • 4 comments

声明一个抽象类EnhanceMessageHandler实现RocketMQListener接口

abstract class EnhanceMessageHandler<T extends BaseMessage> implements RocketMQListener<T>{}

声明一个类实现MchApplymentConsumer extends EnhanceMessageHandler<MchApplymentMessage>实现抽象类EnhanceMessageHandler

DefaultRocketMQListenerContainer的getMessageType返回的Type类型为T

xuziyang avatar Aug 16 '23 07:08 xuziyang

可以继承RocketMQListener<MessageExt>

987472953 avatar Sep 26 '23 11:09 987472953

可以继承RocketMQListener<MessageExt>

我们现在要在RocketMQListener基础上在封装一个抽象基础类

xuziyang avatar Sep 27 '23 07:09 xuziyang

public abstract class MessageHandler<T> implements RocketMQListener<MessageExt> {
    @Override
    public void onMessage(MessageExt messageExt) {
       // 重写消费逻辑
    }
}

987472953 avatar Sep 27 '23 08:09 987472953

public abstract class MessageHandler<T> implements RocketMQListener<MessageExt> {
    @Override
    public void onMessage(MessageExt messageExt) {
       // 重写消费逻辑
    }
}

你试过了吗,这样可以用?

xuziyang avatar Sep 28 '23 00:09 xuziyang