Skip to content

Commit 1da7d55

Browse files
authored
Increase rocketmq request timeout (#7987)
Same as #7968
1 parent d27dd89 commit 1da7d55

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

instrumentation/rocketmq/rocketmq-client/rocketmq-client-5.0/testing/src/main/java/io/opentelemetry/instrumentation/rocketmqclient/v5_0/AbstractRocketMqClientSuppressReceiveSpanTest.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import io.opentelemetry.sdk.trace.data.StatusData;
2525
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
2626
import java.nio.charset.StandardCharsets;
27+
import java.time.Duration;
2728
import java.util.Arrays;
2829
import java.util.Collections;
2930
import org.apache.rocketmq.client.apis.ClientConfiguration;
@@ -57,7 +58,10 @@ static void tearDown() {
5758
@Test
5859
void testSendAndConsumeMessage() throws Throwable {
5960
ClientConfiguration clientConfiguration =
60-
ClientConfiguration.newBuilder().setEndpoints(container.endpoints).build();
61+
ClientConfiguration.newBuilder()
62+
.setEndpoints(container.endpoints)
63+
.setRequestTimeout(Duration.ofSeconds(10))
64+
.build();
6165
// Inner topic of the container.
6266
String topic = "normal-topic-0";
6367
ClientServiceProvider provider = ClientServiceProvider.loadService();

0 commit comments

Comments
 (0)