导语
在前面的分析中分析了关于Producer发送消息的逻辑,并且追踪到了在DefaultMQPushConsumerImpl 类中的有对应的消息监听方法,这个消息监听的方法是从Consumer调用 start()方法就开始启动的,但是从Consumer的示例代码中会看到,并没有像是Producer那样的明显表示Receive的方法而是通过我们下面要分析的方法来实现。 在前面的分析中分析了关于Producer发送消息的逻辑,并且追
导语
在前面的分析中分析了关于Producer发送消息的逻辑,并且追踪到了在DefaultMQPushConsumerImpl 类中的有对应的消息监听方法,这个消息监听的方法是从Consumer调用 start()方法就开始启动的,但是从Consumer的示例代码中会看到,并没有像是Producer那样的明显表示Receive的方法而是通过我们下面要分析的方法来实现。 在前面的分析中分析了关于Producer发送消息的逻辑,并且追