This is an automated email from the ASF dual-hosted git repository.
mxsm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new a350ffc45 [ISSUE #4349][Unit Test] eventmesh-common header unit test.
(#4348)
a350ffc45 is described below
commit a350ffc454a5d2ce91bd5868f242431ee0363376
Author: zhengpeng <[email protected]>
AuthorDate: Fri Aug 11 21:58:21 2023 +0800
[ISSUE #4349][Unit Test] eventmesh-common header unit test. (#4348)
* [ISSUE #4339][Unit Test] eventmesh-common header unit test.
* [ISSUE #4339][Unit Test] eventmesh-common header unit test.
* [ISSUE #4339][Unit Test] eventmesh-common body unit test.
* [ISSUE #4339][Unit Test] eventmesh-common ReflectUtils and
RandomStringUtils unit test.
* [ISSUE #4339]comment.
* [ISSUE #4339]expectedException.
---
.../eventmesh/common/config/ConfigService.java | 4 +-
.../eventmesh/common/utils/HttpConvertsUtils.java | 10 ++-
.../eventmesh/common/utils/ReflectUtils.java | 4 +-
.../common/protocol/http/body/BodyTest.java | 91 ++++++++++++++++++++++
.../common/protocol/http/header/HeaderTest.java | 91 ++++++++++++++++++++++
.../common/utils/RandomStringUtilsTest.java} | 39 ++++------
.../eventmesh/common/utils/ReflectUtilsTest.java} | 54 +++++++------
.../trace/jaeger/JaegerTraceServiceTest.java | 2 +-
.../trace/pinpoint/PinpointTraceServiceTest.java | 2 +-
.../trace/zipkin/ZipkinTraceServiceTest.java | 2 +-
10 files changed, 245 insertions(+), 54 deletions(-)
diff --git
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigService.java
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigService.java
index 1f1fc398b..7c5b17d7e 100644
---
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigService.java
+++
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigService.java
@@ -17,7 +17,7 @@
package org.apache.eventmesh.common.config;
-import static org.apache.eventmesh.common.utils.ReflectUtils.lookUpField;
+import static
org.apache.eventmesh.common.utils.ReflectUtils.lookUpFieldByParentClass;
import org.apache.commons.lang3.StringUtils;
@@ -160,7 +160,7 @@ public class ConfigService {
try {
field = clazz.getDeclaredField(configInfo.getField());
} catch (NoSuchFieldException e) {
- field = lookUpField(clazz, configInfo.getField());
+ field = lookUpFieldByParentClass(clazz, configInfo.getField());
if (field == null) {
throw e;
}
diff --git
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/HttpConvertsUtils.java
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/HttpConvertsUtils.java
index e79cb4249..0661c4e68 100644
---
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/HttpConvertsUtils.java
+++
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/HttpConvertsUtils.java
@@ -29,6 +29,7 @@ import java.lang.reflect.Field;
import java.util.EnumSet;
import java.util.HashMap;
import java.util.Map;
+import java.util.Objects;
import lombok.extern.slf4j.Slf4j;
@@ -171,7 +172,10 @@ public class HttpConvertsUtils {
protocolKeyField.setAccessible(true);
switch (headerFieldName) {
case ProtocolKey.VERSION:
- headerField.set(header,
ProtocolVersion.get(MapUtils.getString(headerParam, ProtocolKey.VERSION)));
+ ProtocolVersion protocolVersion =
ProtocolVersion.get(MapUtils.getString(headerParam, ProtocolKey.VERSION));
+ if (Objects.nonNull(protocolVersion)) {
+ headerField.set(header, protocolVersion);
+ }
break;
case ProtocolKey.LANGUAGE:
String language =
StringUtils.isBlank(MapUtils.getString(headerParam, ProtocolKey.LANGUAGE))
@@ -183,7 +187,9 @@ public class HttpConvertsUtils {
// Use the attribute name to compare with the key value to
achieve one-to-one correspondence and ignore case.
if (StringUtils.equalsIgnoreCase(headerFieldName,
protocolKeyValue)) {
Object value = getValue(headerParam, protocolKeyValue);
- headerField.set(header, value);
+ if (Objects.nonNull(value)) {
+ headerField.set(header, value);
+ }
}
break;
}
diff --git
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ReflectUtils.java
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ReflectUtils.java
index f3572b5b6..44fac016a 100644
---
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ReflectUtils.java
+++
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ReflectUtils.java
@@ -23,13 +23,13 @@ import java.lang.reflect.Modifier;
public class ReflectUtils {
/**
- * Look up fields inherited from the parent class.
+ * Look up not private fields inherited from the parent class.
*
* @param clazz
* @param fieldName
* @return
*/
- public static Field lookUpField(Class<?> clazz, String fieldName) {
+ public static Field lookUpFieldByParentClass(Class<?> clazz, String
fieldName) {
Class<?> superClass = clazz.getSuperclass();
while (superClass != null) {
Field[] superFields = superClass.getDeclaredFields();
diff --git
a/eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/body/BodyTest.java
b/eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/body/BodyTest.java
new file mode 100644
index 000000000..cc27e6f28
--- /dev/null
+++
b/eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/body/BodyTest.java
@@ -0,0 +1,91 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.common.protocol.http.body;
+
+import
org.apache.eventmesh.common.protocol.http.body.client.HeartbeatRequestBody;
+import org.apache.eventmesh.common.protocol.http.body.client.RegRequestBody;
+import
org.apache.eventmesh.common.protocol.http.body.client.SubscribeRequestBody;
+import org.apache.eventmesh.common.protocol.http.body.client.UnRegRequestBody;
+import
org.apache.eventmesh.common.protocol.http.body.client.UnSubscribeRequestBody;
+import
org.apache.eventmesh.common.protocol.http.body.message.PushMessageRequestBody;
+import
org.apache.eventmesh.common.protocol.http.body.message.ReplyMessageRequestBody;
+import
org.apache.eventmesh.common.protocol.http.body.message.SendMessageBatchRequestBody;
+import
org.apache.eventmesh.common.protocol.http.body.message.SendMessageBatchV2RequestBody;
+import
org.apache.eventmesh.common.protocol.http.body.message.SendMessageRequestBody;
+import org.apache.eventmesh.common.protocol.http.common.RequestCode;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+
+public class BodyTest {
+
+ private Map<String, Object> originalMap;
+
+ @Before
+ public void before() {
+ originalMap = new HashMap<>();
+ }
+
+ @Test
+ public void testBuildBody() throws Exception {
+ Assert.assertThrows(Exception.class, () -> Body.buildBody("-1",
originalMap));
+ Body sendMessageBatchRequestBody =
Body.buildBody(String.valueOf(RequestCode.MSG_BATCH_SEND.getRequestCode()),
originalMap);
+ Assert.assertNotNull(sendMessageBatchRequestBody);
+ Assert.assertEquals(sendMessageBatchRequestBody.getClass(),
SendMessageBatchRequestBody.class);
+ Body sendMessageBatchV2RequestBody =
Body.buildBody(String.valueOf(RequestCode.MSG_BATCH_SEND_V2.getRequestCode()),
originalMap);
+ Assert.assertNotNull(sendMessageBatchV2RequestBody);
+ Assert.assertEquals(sendMessageBatchV2RequestBody.getClass(),
SendMessageBatchV2RequestBody.class);
+ Body sendMessageRequestBodySync =
Body.buildBody(String.valueOf(RequestCode.MSG_SEND_SYNC.getRequestCode()),
originalMap);
+ Assert.assertNotNull(sendMessageRequestBodySync);
+ Assert.assertEquals(sendMessageRequestBodySync.getClass(),
SendMessageRequestBody.class);
+ Body sendMessageRequestBodyAsync =
Body.buildBody(String.valueOf(RequestCode.MSG_SEND_ASYNC.getRequestCode()),
originalMap);
+ Assert.assertNotNull(sendMessageRequestBodyAsync);
+ Assert.assertEquals(sendMessageRequestBodyAsync.getClass(),
SendMessageRequestBody.class);
+ Body pushMessageRequestBodySync =
Body.buildBody(String.valueOf(RequestCode.HTTP_PUSH_CLIENT_SYNC.getRequestCode()),
originalMap);
+ Assert.assertNotNull(pushMessageRequestBodySync);
+ Assert.assertEquals(pushMessageRequestBodySync.getClass(),
PushMessageRequestBody.class);
+ Body pushMessageRequestBodyAsync =
Body.buildBody(String.valueOf(RequestCode.HTTP_PUSH_CLIENT_ASYNC.getRequestCode()),
originalMap);
+ Assert.assertNotNull(pushMessageRequestBodyAsync);
+ Assert.assertEquals(pushMessageRequestBodyAsync.getClass(),
PushMessageRequestBody.class);
+ Body regRequestBody =
Body.buildBody(String.valueOf(RequestCode.REGISTER.getRequestCode()),
originalMap);
+ Assert.assertNotNull(regRequestBody);
+ Assert.assertEquals(regRequestBody.getClass(), RegRequestBody.class);
+ Body unRegRequestBody =
Body.buildBody(String.valueOf(RequestCode.UNREGISTER.getRequestCode()),
originalMap);
+ Assert.assertNotNull(unRegRequestBody);
+ Assert.assertEquals(unRegRequestBody.getClass(),
UnRegRequestBody.class);
+ Body subscribeRequestBody =
Body.buildBody(String.valueOf(RequestCode.SUBSCRIBE.getRequestCode()),
originalMap);
+ Assert.assertNotNull(subscribeRequestBody);
+ Assert.assertEquals(subscribeRequestBody.getClass(),
SubscribeRequestBody.class);
+ Body unSubscribeRequestBody =
Body.buildBody(String.valueOf(RequestCode.UNSUBSCRIBE.getRequestCode()),
originalMap);
+ Assert.assertNotNull(unSubscribeRequestBody);
+ Assert.assertEquals(unSubscribeRequestBody.getClass(),
UnSubscribeRequestBody.class);
+ Body heartbeatRequestBody =
Body.buildBody(String.valueOf(RequestCode.HEARTBEAT.getRequestCode()),
originalMap);
+ Assert.assertNotNull(heartbeatRequestBody);
+ Assert.assertEquals(heartbeatRequestBody.getClass(),
HeartbeatRequestBody.class);
+ Body replyMessageRequestBody =
Body.buildBody(String.valueOf(RequestCode.REPLY_MESSAGE.getRequestCode()),
originalMap);
+ Assert.assertNotNull(replyMessageRequestBody);
+ Assert.assertEquals(replyMessageRequestBody.getClass(),
ReplyMessageRequestBody.class);
+ Body baseRequestBody =
Body.buildBody(String.valueOf(RequestCode.ADMIN_SHUTDOWN.getRequestCode()),
originalMap);
+ Assert.assertNotNull(baseRequestBody);
+ Assert.assertEquals(baseRequestBody.getClass(), BaseRequestBody.class);
+ }
+}
diff --git
a/eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/HeaderTest.java
b/eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/HeaderTest.java
new file mode 100644
index 000000000..e6766237b
--- /dev/null
+++
b/eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/HeaderTest.java
@@ -0,0 +1,91 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.common.protocol.http.header;
+
+import org.apache.eventmesh.common.protocol.http.common.RequestCode;
+import
org.apache.eventmesh.common.protocol.http.header.client.HeartbeatRequestHeader;
+import
org.apache.eventmesh.common.protocol.http.header.client.RegRequestHeader;
+import
org.apache.eventmesh.common.protocol.http.header.client.SubscribeRequestHeader;
+import
org.apache.eventmesh.common.protocol.http.header.client.UnRegRequestHeader;
+import
org.apache.eventmesh.common.protocol.http.header.client.UnSubscribeRequestHeader;
+import
org.apache.eventmesh.common.protocol.http.header.message.PushMessageRequestHeader;
+import
org.apache.eventmesh.common.protocol.http.header.message.ReplyMessageRequestHeader;
+import
org.apache.eventmesh.common.protocol.http.header.message.SendMessageBatchRequestHeader;
+import
org.apache.eventmesh.common.protocol.http.header.message.SendMessageBatchV2RequestHeader;
+import
org.apache.eventmesh.common.protocol.http.header.message.SendMessageRequestHeader;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+
+public class HeaderTest {
+
+ private Map<String, Object> originalMap;
+
+ @Before
+ public void before() {
+ originalMap = new HashMap<>();
+ }
+
+ @Test
+ public void testBuildHeader() throws Exception {
+ Assert.assertThrows(Exception.class, () -> Header.buildHeader("-1",
originalMap));
+ Header messageBatchRequestHeader =
Header.buildHeader(String.valueOf(RequestCode.MSG_BATCH_SEND.getRequestCode()),
originalMap);
+ Assert.assertNotNull(messageBatchRequestHeader);
+ Assert.assertEquals(messageBatchRequestHeader.getClass(),
SendMessageBatchRequestHeader.class);
+ Header sendMessageBatchV2RequestHeader =
Header.buildHeader(String.valueOf(RequestCode.MSG_BATCH_SEND_V2.getRequestCode()),
originalMap);
+ Assert.assertNotNull(sendMessageBatchV2RequestHeader);
+ Assert.assertEquals(sendMessageBatchV2RequestHeader.getClass(),
SendMessageBatchV2RequestHeader.class);
+ Header sendMessageRequestHeaderSync =
Header.buildHeader(String.valueOf(RequestCode.MSG_SEND_SYNC.getRequestCode()),
originalMap);
+ Assert.assertNotNull(sendMessageRequestHeaderSync);
+ Assert.assertEquals(sendMessageRequestHeaderSync.getClass(),
SendMessageRequestHeader.class);
+ Header sendMessageRequestHeaderAsync =
Header.buildHeader(String.valueOf(RequestCode.MSG_SEND_ASYNC.getRequestCode()),
originalMap);
+ Assert.assertNotNull(sendMessageRequestHeaderAsync);
+ Assert.assertEquals(sendMessageRequestHeaderAsync.getClass(),
SendMessageRequestHeader.class);
+ Header pushMessageRequestHeaderSync =
Header.buildHeader(String.valueOf(RequestCode.HTTP_PUSH_CLIENT_SYNC.getRequestCode()),
originalMap);
+ Assert.assertNotNull(pushMessageRequestHeaderSync);
+ Assert.assertEquals(pushMessageRequestHeaderSync.getClass(),
PushMessageRequestHeader.class);
+ Header pushMessageRequestHeaderAsync =
Header.buildHeader(String.valueOf(RequestCode.HTTP_PUSH_CLIENT_ASYNC.getRequestCode()),
originalMap);
+ Assert.assertNotNull(pushMessageRequestHeaderAsync);
+ Assert.assertEquals(pushMessageRequestHeaderAsync.getClass(),
PushMessageRequestHeader.class);
+ Header regRequestHeader =
Header.buildHeader(String.valueOf(RequestCode.REGISTER.getRequestCode()),
originalMap);
+ Assert.assertNotNull(regRequestHeader);
+ Assert.assertEquals(regRequestHeader.getClass(),
RegRequestHeader.class);
+ Header unRegRequestHeader =
Header.buildHeader(String.valueOf(RequestCode.UNREGISTER.getRequestCode()),
originalMap);
+ Assert.assertNotNull(unRegRequestHeader);
+ Assert.assertEquals(unRegRequestHeader.getClass(),
UnRegRequestHeader.class);
+ Header subscribeRequestHeader =
Header.buildHeader(String.valueOf(RequestCode.SUBSCRIBE.getRequestCode()),
originalMap);
+ Assert.assertNotNull(subscribeRequestHeader);
+ Assert.assertEquals(subscribeRequestHeader.getClass(),
SubscribeRequestHeader.class);
+ Header unSubscribeRequestHeader =
Header.buildHeader(String.valueOf(RequestCode.UNSUBSCRIBE.getRequestCode()),
originalMap);
+ Assert.assertNotNull(unSubscribeRequestHeader);
+ Assert.assertEquals(unSubscribeRequestHeader.getClass(),
UnSubscribeRequestHeader.class);
+ Header heartbeatRequestHeader =
Header.buildHeader(String.valueOf(RequestCode.HEARTBEAT.getRequestCode()),
originalMap);
+ Assert.assertNotNull(heartbeatRequestHeader);
+ Assert.assertEquals(heartbeatRequestHeader.getClass(),
HeartbeatRequestHeader.class);
+ Header replyMessageRequestHeader =
Header.buildHeader(String.valueOf(RequestCode.REPLY_MESSAGE.getRequestCode()),
originalMap);
+ Assert.assertNotNull(replyMessageRequestHeader);
+ Assert.assertEquals(replyMessageRequestHeader.getClass(),
ReplyMessageRequestHeader.class);
+ Header baseRequestHeader =
Header.buildHeader(String.valueOf(RequestCode.ADMIN_SHUTDOWN.getRequestCode()),
originalMap);
+ Assert.assertNotNull(baseRequestHeader);
+ Assert.assertEquals(baseRequestHeader.getClass(),
BaseRequestHeader.class);
+ }
+}
diff --git
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ReflectUtils.java
b/eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/RandomStringUtilsTest.java
similarity index 52%
copy from
eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ReflectUtils.java
copy to
eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/RandomStringUtilsTest.java
index f3572b5b6..2360381bb 100644
---
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ReflectUtils.java
+++
b/eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/RandomStringUtilsTest.java
@@ -17,29 +17,24 @@
package org.apache.eventmesh.common.utils;
-import java.lang.reflect.Field;
-import java.lang.reflect.Modifier;
+import org.apache.commons.lang3.math.NumberUtils;
-public class ReflectUtils {
+import org.junit.Assert;
+import org.junit.Test;
- /**
- * Look up fields inherited from the parent class.
- *
- * @param clazz
- * @param fieldName
- * @return
- */
- public static Field lookUpField(Class<?> clazz, String fieldName) {
- Class<?> superClass = clazz.getSuperclass();
- while (superClass != null) {
- Field[] superFields = superClass.getDeclaredFields();
- for (Field superField : superFields) {
- if (!Modifier.isPrivate(superField.getModifiers()) &&
superField.getName().equals(fieldName)) {
- return superField;
- }
- }
- superClass = superClass.getSuperclass();
- }
- return null;
+public class RandomStringUtilsTest {
+
+ @Test
+ public void testGenerateNum() {
+ String result = RandomStringUtils.generateNum(2);
+ Assert.assertTrue(NumberUtils.isDigits(result));
+ Assert.assertEquals(2, result.length());
+ }
+
+ @Test
+ public void testGenerateUUID() {
+ String result = RandomStringUtils.generateUUID();
+
Assert.assertTrue(result.matches("^\\w{8}-\\w{4}-\\w{4}-\\w{4}-\\w{12}$"));
}
+
}
diff --git
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ReflectUtils.java
b/eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/ReflectUtilsTest.java
similarity index 52%
copy from
eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ReflectUtils.java
copy to
eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/ReflectUtilsTest.java
index f3572b5b6..2f549b3bd 100644
---
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ReflectUtils.java
+++
b/eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/ReflectUtilsTest.java
@@ -18,28 +18,36 @@
package org.apache.eventmesh.common.utils;
import java.lang.reflect.Field;
-import java.lang.reflect.Modifier;
-
-public class ReflectUtils {
-
- /**
- * Look up fields inherited from the parent class.
- *
- * @param clazz
- * @param fieldName
- * @return
- */
- public static Field lookUpField(Class<?> clazz, String fieldName) {
- Class<?> superClass = clazz.getSuperclass();
- while (superClass != null) {
- Field[] superFields = superClass.getDeclaredFields();
- for (Field superField : superFields) {
- if (!Modifier.isPrivate(superField.getModifiers()) &&
superField.getName().equals(fieldName)) {
- return superField;
- }
- }
- superClass = superClass.getSuperclass();
- }
- return null;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class ReflectUtilsTest {
+
+ public static class TestParent {
+
+ private String age;
+
+ public String tel;
+
}
+
+ public static class TestObj extends TestParent {
+
+ private String name;
+
+ private String password;
+ }
+
+ @Test
+ public void testLookUpFieldByParentClass() {
+ Field fieldName = ReflectUtils.lookUpFieldByParentClass(TestObj.class,
"name");
+ Field fieldAge = ReflectUtils.lookUpFieldByParentClass(TestObj.class,
"age");
+ Field fieldTel = ReflectUtils.lookUpFieldByParentClass(TestObj.class,
"tel");
+ Assert.assertNull(fieldName);
+ Assert.assertNull(fieldAge);
+ Assert.assertNotNull(fieldTel);
+ Assert.assertEquals("tel", fieldTel.getName());
+ }
+
}
diff --git
a/eventmesh-trace-plugin/eventmesh-trace-jaeger/src/test/java/org/apache/eventmesh/trace/jaeger/JaegerTraceServiceTest.java
b/eventmesh-trace-plugin/eventmesh-trace-jaeger/src/test/java/org/apache/eventmesh/trace/jaeger/JaegerTraceServiceTest.java
index 5067ce3dd..281330f13 100644
---
a/eventmesh-trace-plugin/eventmesh-trace-jaeger/src/test/java/org/apache/eventmesh/trace/jaeger/JaegerTraceServiceTest.java
+++
b/eventmesh-trace-plugin/eventmesh-trace-jaeger/src/test/java/org/apache/eventmesh/trace/jaeger/JaegerTraceServiceTest.java
@@ -57,7 +57,7 @@ public class JaegerTraceServiceTest {
try {
sdkTracerProviderField =
JaegerTraceService.class.getDeclaredField("sdkTracerProvider");
} catch (NoSuchFieldException e) {
- sdkTracerProviderField =
ReflectUtils.lookUpField(JaegerTraceService.class, "sdkTracerProvider");
+ sdkTracerProviderField =
ReflectUtils.lookUpFieldByParentClass(JaegerTraceService.class,
"sdkTracerProvider");
if (sdkTracerProviderField == null) {
throw e;
}
diff --git
a/eventmesh-trace-plugin/eventmesh-trace-pinpoint/src/test/java/org/apache/eventmesh/trace/pinpoint/PinpointTraceServiceTest.java
b/eventmesh-trace-plugin/eventmesh-trace-pinpoint/src/test/java/org/apache/eventmesh/trace/pinpoint/PinpointTraceServiceTest.java
index 4b06140c3..70bcc963a 100644
---
a/eventmesh-trace-plugin/eventmesh-trace-pinpoint/src/test/java/org/apache/eventmesh/trace/pinpoint/PinpointTraceServiceTest.java
+++
b/eventmesh-trace-plugin/eventmesh-trace-pinpoint/src/test/java/org/apache/eventmesh/trace/pinpoint/PinpointTraceServiceTest.java
@@ -53,7 +53,7 @@ public class PinpointTraceServiceTest {
try {
sdkTracerProviderField =
PinpointTraceService.class.getDeclaredField("sdkTracerProvider");
} catch (NoSuchFieldException e) {
- sdkTracerProviderField =
ReflectUtils.lookUpField(PinpointTraceService.class, "sdkTracerProvider");
+ sdkTracerProviderField =
ReflectUtils.lookUpFieldByParentClass(PinpointTraceService.class,
"sdkTracerProvider");
if (sdkTracerProviderField == null) {
throw e;
}
diff --git
a/eventmesh-trace-plugin/eventmesh-trace-zipkin/src/test/java/org/apache/eventmesh/trace/zipkin/ZipkinTraceServiceTest.java
b/eventmesh-trace-plugin/eventmesh-trace-zipkin/src/test/java/org/apache/eventmesh/trace/zipkin/ZipkinTraceServiceTest.java
index 747ec166d..3e5ae0558 100644
---
a/eventmesh-trace-plugin/eventmesh-trace-zipkin/src/test/java/org/apache/eventmesh/trace/zipkin/ZipkinTraceServiceTest.java
+++
b/eventmesh-trace-plugin/eventmesh-trace-zipkin/src/test/java/org/apache/eventmesh/trace/zipkin/ZipkinTraceServiceTest.java
@@ -56,7 +56,7 @@ public class ZipkinTraceServiceTest {
try {
sdkTracerProviderField =
ZipkinTraceService.class.getDeclaredField("sdkTracerProvider");
} catch (NoSuchFieldException e) {
- sdkTracerProviderField =
ReflectUtils.lookUpField(ZipkinTraceService.class, "sdkTracerProvider");
+ sdkTracerProviderField =
ReflectUtils.lookUpFieldByParentClass(ZipkinTraceService.class,
"sdkTracerProvider");
if (sdkTracerProviderField == null) {
throw e;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
