activemq调用MessageListener.onMessage方法源码分析

johnhuster的分享

发布于 2022-03-29 14:26:21

3250

发布于 2022-03-29 14:26:21

文章被收录于专栏：johnhuster

activemq客户端调用MessageListener.onMessage方法的执行路径如下：

ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)

-->ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)

-->org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:47)

-->org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:129)

-->org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:191)

-->org.apache.activemq.ActiveMQMessageConsumer.iterate(ActiveMQMessageConsumer.java:1460)

-->org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1321)

-->xx.onMessage(具体MessageListener实现类的onMessage方法)

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2018/08/15 ，如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

登录后参与评论

0 条评论

热度