opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #6714] Replace the deprecated method DefaultMQPushConsumer#getDefaultMQPushConsumerImpl (#6715)

Browse Source
This commit is contained in:
mxsm
2023-05-10 09:59:18 +08:00
committed by GitHub
parent 09ad52b9e1
commit f33ac2a3ec
6 changed files with 20 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingPushConsumer.java
+1 -1
View File
@@ -41,7 +41,7 @@ public class OpenTracingPushConsumer {
// Uncomment the following line while debugging, namesrvAddr should be set to your local address
// consumer.setNamesrvAddr(DEFAULT_NAMESRVADDR);
consumer.getDefaultMQPushConsumerImpl().registerConsumeMessageHook(new ConsumeMessageOpenTracingHookImpl(tracer));
consumer.registerConsumeMessageHook(new ConsumeMessageOpenTracingHookImpl(tracer));
consumer.subscribe(TOPIC, "*");
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);