public interface IMessageConsumer<T> extends RocketMQListener<T> {
}
Due to project needs, some personalized business operations need to extend the RocketMQListener interface.
I need to override the DefaultRocketMQListenerContainer#getMessageType() method to complete my custom extension.
ruansheng8
commented
3 months ago
What is the purpose of the change
Due to project needs, some personalized business operations need to extend the
RocketMQListenerinterface. I need to override theDefaultRocketMQListenerContainer#getMessageType()method to complete my custom extension.