Skip to content

Commit dbb1b7f

Browse files
authored
Increase rocketmq request timeout (#7968)
Hopefully avoids exceptions like `org.apache.rocketmq.shaded.io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after...` in rocketmq 5 test setup.
1 parent 293ef46 commit dbb1b7f

File tree

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

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/AbstractRocketMqClientTest.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@
3535
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
3636
import java.io.IOException;
3737
import java.nio.charset.StandardCharsets;
38+
import java.time.Duration;
3839
import java.util.ArrayList;
3940
import java.util.Arrays;
4041
import java.util.Collections;
@@ -79,7 +80,10 @@ public abstract class AbstractRocketMqClientTest {
7980
void setUp() throws ClientException {
8081
container.start();
8182
ClientConfiguration clientConfiguration =
82-
ClientConfiguration.newBuilder().setEndpoints(container.endpoints).build();
83+
ClientConfiguration.newBuilder()
84+
.setEndpoints(container.endpoints)
85+
.setRequestTimeout(Duration.ofSeconds(10))
86+
.build();
8387
FilterExpression filterExpression = new FilterExpression(tag, FilterExpressionType.TAG);
8488
Map<String, FilterExpression> subscriptionExpressions = new HashMap<>();
8589
subscriptionExpressions.put(normalTopic, filterExpression);

0 commit comments

Comments
 (0)