This is an automated email from the ASF dual-hosted git repository.
yukon pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 852b635e51 [ISSUE #8396] Fix typo in TraceConstants (#8398)
852b635e51 is described below
commit 852b635e515de223fcfce13c3c87b0bc2061ac49
Author: yx9o <[email protected]>
AuthorDate: Thu Jul 18 11:11:58 2024 +0800
[ISSUE #8396] Fix typo in TraceConstants (#8398)
* [ISSUE #8396] Fix typo in TraceConstants
* Update
* Update
* Update
* Update
* Update
* Update
---
.../src/main/java/org/apache/rocketmq/client/trace/TraceConstants.java | 2 +-
.../rocketmq/client/trace/hook/EndTransactionOpenTracingHookImpl.java | 2 +-
.../rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java | 2 +-
.../rocketmq/client/trace/DefaultMQProducerWithOpenTracingTest.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/client/src/main/java/org/apache/rocketmq/client/trace/TraceConstants.java
b/client/src/main/java/org/apache/rocketmq/client/trace/TraceConstants.java
index 1ad4b61051..67f7ab3f8f 100644
--- a/client/src/main/java/org/apache/rocketmq/client/trace/TraceConstants.java
+++ b/client/src/main/java/org/apache/rocketmq/client/trace/TraceConstants.java
@@ -32,7 +32,7 @@ public class TraceConstants {
public static final String ROCKETMQ_SUCCESS = "rocketmq.success";
public static final String ROCKETMQ_TAGS = "rocketmq.tags";
public static final String ROCKETMQ_KEYS = "rocketmq.keys";
- public static final String ROCKETMQ_SOTRE_HOST = "rocketmq.store_host";
+ public static final String ROCKETMQ_STORE_HOST = "rocketmq.store_host";
public static final String ROCKETMQ_BODY_LENGTH = "rocketmq.body_length";
public static final String ROCKETMQ_MSG_ID = "rocketmq.mgs_id";
public static final String ROCKETMQ_MSG_TYPE = "rocketmq.mgs_type";
diff --git
a/client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionOpenTracingHookImpl.java
b/client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionOpenTracingHookImpl.java
index 62d310f196..44e4b69776 100644
---
a/client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionOpenTracingHookImpl.java
+++
b/client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionOpenTracingHookImpl.java
@@ -60,7 +60,7 @@ public class EndTransactionOpenTracingHookImpl implements
EndTransactionHook {
span.setTag(Tags.MESSAGE_BUS_DESTINATION, msg.getTopic());
span.setTag(TraceConstants.ROCKETMQ_TAGS, msg.getTags());
span.setTag(TraceConstants.ROCKETMQ_KEYS, msg.getKeys());
- span.setTag(TraceConstants.ROCKETMQ_SOTRE_HOST,
context.getBrokerAddr());
+ span.setTag(TraceConstants.ROCKETMQ_STORE_HOST,
context.getBrokerAddr());
span.setTag(TraceConstants.ROCKETMQ_MSG_ID, context.getMsgId());
span.setTag(TraceConstants.ROCKETMQ_MSG_TYPE,
MessageType.Trans_msg_Commit.name());
span.setTag(TraceConstants.ROCKETMQ_TRANSACTION_ID,
context.getTransactionId());
diff --git
a/client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java
b/client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java
index 60c18a22a7..3cb6493384 100644
---
a/client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java
+++
b/client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java
@@ -60,7 +60,7 @@ public class SendMessageOpenTracingHookImpl implements
SendMessageHook {
span.setTag(Tags.MESSAGE_BUS_DESTINATION, msg.getTopic());
span.setTag(TraceConstants.ROCKETMQ_TAGS, msg.getTags());
span.setTag(TraceConstants.ROCKETMQ_KEYS, msg.getKeys());
- span.setTag(TraceConstants.ROCKETMQ_SOTRE_HOST,
context.getBrokerAddr());
+ span.setTag(TraceConstants.ROCKETMQ_STORE_HOST,
context.getBrokerAddr());
span.setTag(TraceConstants.ROCKETMQ_MSG_TYPE,
context.getMsgType().name());
span.setTag(TraceConstants.ROCKETMQ_BODY_LENGTH, msg.getBody().length);
context.setMqTraceContext(span);
diff --git
a/client/src/test/java/org/apache/rocketmq/client/trace/DefaultMQProducerWithOpenTracingTest.java
b/client/src/test/java/org/apache/rocketmq/client/trace/DefaultMQProducerWithOpenTracingTest.java
index 9ce9d6b494..c0eb8568dc 100644
---
a/client/src/test/java/org/apache/rocketmq/client/trace/DefaultMQProducerWithOpenTracingTest.java
+++
b/client/src/test/java/org/apache/rocketmq/client/trace/DefaultMQProducerWithOpenTracingTest.java
@@ -124,7 +124,7 @@ public class DefaultMQProducerWithOpenTracingTest {
assertThat(span.tags().get(TraceConstants.ROCKETMQ_BODY_LENGTH)).isEqualTo(3);
assertThat(span.tags().get(TraceConstants.ROCKETMQ_REGION_ID)).isEqualTo("HZ");
assertThat(span.tags().get(TraceConstants.ROCKETMQ_MSG_TYPE)).isEqualTo(MessageType.Normal_Msg.name());
-
assertThat(span.tags().get(TraceConstants.ROCKETMQ_SOTRE_HOST)).isEqualTo("127.0.0.1:10911");
+
assertThat(span.tags().get(TraceConstants.ROCKETMQ_STORE_HOST)).isEqualTo("127.0.0.1:10911");
}
@After
