diff --git a/instrumentation/rocketmq/rocketmq-client/rocketmq-client-4.8/library/README.md b/instrumentation/rocketmq/rocketmq-client/rocketmq-client-4.8/library/README.md index 73761eab77c0..5184a73184fd 100644 --- a/instrumentation/rocketmq/rocketmq-client/rocketmq-client-4.8/library/README.md +++ b/instrumentation/rocketmq/rocketmq-client/rocketmq-client-4.8/library/README.md @@ -1,6 +1,6 @@ # Library Instrumentation for Apache RocketMQ Remoting-based Client version 4.0.0+ -Provides OpenTelemetry instrumentation for [Apache RocketMQ](https://rocketmq.apache.org/) Remoting-based Client. +Provides OpenTelemetry instrumentation for [Apache RocketMQ](https://rocketmq.apache.org/) remoting-based client. ## Quickstart @@ -12,7 +12,6 @@ release](https://search.maven.org/search?q=g:io.opentelemetry.instrumentation%20 For Maven, add the following to your `pom.xml` dependencies: ```xml - io.opentelemetry.instrumentation @@ -38,10 +37,8 @@ RocketMqTelemetry rocketMqTelemetry; void configure(OpenTelemetry openTelemetry, DefaultMQProducerImpl producer, DefaultMQPushConsumerImpl pushConsumer) { rocketMqTelemetry = RocketMqTelemetry.create(openTelemetry); // For producer. - SendMessageHook sendMessageHook = rocketMqTelemetry.newTracingSendMessageHook(); - producer.registerSendMessageHook(sendMessageHook); + producer.registerSendMessageHook(rocketMqTelemetry.newTracingSendMessageHook()); // For push consumer. - ConsumeMessageHook consumeMessageHook = rocketMqTelemetry.newTracingConsumeMessageHook(); - pushConsumer.registerConsumeMessageHook(consumeMessageHook); + pushConsumer.registerConsumeMessageHook(rocketMqTelemetry.newTracingConsumeMessageHook()); } ```