open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove redundant code in AbstractRocketMqClientTest (#7285)

This commit is contained in:
Aaron Ai 2022-11-24 00:21:28 +08:00 committed by GitHub
parent ac82016fdd
commit 85b3644787
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
instrumentation/rocketmq/rocketmq-client/rocketmq-client-5.0/testing/src/main/java/io/opentelemetry/instrumentation/rocketmqclient/v5_0/AbstractRocketMqClientTest.java
View File

@ -72,9 +72,6 @@ public abstract class AbstractRocketMqClientTest {
container.start(); container.start();
ClientConfiguration clientConfiguration = ClientConfiguration clientConfiguration =
ClientConfiguration.newBuilder().setEndpoints(container.endpoints).build(); ClientConfiguration.newBuilder().setEndpoints(container.endpoints).build();
// Inner topic of the container.
ClientServiceProvider provider = ClientServiceProvider.loadService();
String consumerGroup = "group-normal-topic-0";
FilterExpression filterExpression = new FilterExpression(tag, FilterExpressionType.TAG); FilterExpression filterExpression = new FilterExpression(tag, FilterExpressionType.TAG);
consumer = consumer =
provider provider
@ -253,7 +250,7 @@ public abstract class AbstractRocketMqClientTest {
equalTo( equalTo(
AttributeKey.stringArrayKey( AttributeKey.stringArrayKey(
"messaging.header.test_message_header"), "messaging.header.test_message_header"),
Arrays.asList(new String[] {"test"}))) Collections.singletonList("test")))
.hasParent(trace.getSpan(0))); .hasParent(trace.getSpan(0)));
sendSpanData.set(trace.getSpan(1)); sendSpanData.set(trace.getSpan(1));
}, },
@ -273,7 +270,7 @@ public abstract class AbstractRocketMqClientTest {
equalTo( equalTo(
AttributeKey.stringArrayKey( AttributeKey.stringArrayKey(
"messaging.header.test_message_header"), "messaging.header.test_message_header"),
Arrays.asList(new String[] {"test"}))) Collections.singletonList("test")))
// As the child of receive span. // As the child of receive span.
.hasParent(trace.getSpan(0)), .hasParent(trace.getSpan(0)),
span -> span ->