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

Increase timeout in opamp-client tests (#2079)

This commit is contained in:
Trask Stalnaker 2025-08-11 02:40:16 -07:00 committed by GitHub
parent 7a645ed7f9
commit 123b1cc890
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
opamp-client/src/test/java/io/opentelemetry/opamp/client/internal/impl/OpampClientImplTest.java
View File

@ -209,7 +209,7 @@ class OpampClientImplTest {
requestService.sendRequest(); requestService.sendRequest();
// Await for onMessage call // Await for onMessage call
await().atMost(Duration.ofSeconds(1)).until(() -> callbacks.onMessageCalls.get() == 1); await().atMost(Duration.ofSeconds(5)).until(() -> callbacks.onMessageCalls.get() == 1);
verify(callbacks).onMessage(MessageData.builder().setRemoteConfig(remoteConfig).build()); verify(callbacks).onMessage(MessageData.builder().setRemoteConfig(remoteConfig).build());
} }
@ -267,7 +267,7 @@ class OpampClientImplTest {
void onConnectionSuccessful_notifyCallback() { void onConnectionSuccessful_notifyCallback() {
initializeClient(); initializeClient();
await().atMost(Duration.ofSeconds(1)).until(() -> callbacks.onConnectCalls.get() == 1); await().atMost(Duration.ofSeconds(5)).until(() -> callbacks.onConnectCalls.get() == 1);
verify(callbacks).onConnect(); verify(callbacks).onConnect();
verify(callbacks, never()).onConnectFailed(any()); verify(callbacks, never()).onConnectFailed(any());
@ -311,7 +311,7 @@ class OpampClientImplTest {
// Force request // Force request
requestService.sendRequest(); requestService.sendRequest();
await().atMost(Duration.ofSeconds(1)).until(() -> callbacks.onErrorResponseCalls.get() == 1); await().atMost(Duration.ofSeconds(5)).until(() -> callbacks.onErrorResponseCalls.get() == 1);
verify(callbacks).onErrorResponse(errorResponse); verify(callbacks).onErrorResponse(errorResponse);
verify(callbacks, never()).onMessage(any()); verify(callbacks, never()).onMessage(any());
@ -344,7 +344,7 @@ class OpampClientImplTest {
enqueueServerToAgentResponse(response); enqueueServerToAgentResponse(response);
requestService.sendRequest(); requestService.sendRequest();
await().atMost(Duration.ofSeconds(1)).until(() -> state.instanceUid.get() != initialUid); await().atMost(Duration.ofSeconds(5)).until(() -> state.instanceUid.get() != initialUid);
assertThat(state.instanceUid.get()).isEqualTo(serverProvidedUid); assertThat(state.instanceUid.get()).isEqualTo(serverProvidedUid);
} }
@ -359,7 +359,7 @@ class OpampClientImplTest {
private RecordedRequest takeRequest() { private RecordedRequest takeRequest() {
try { try {
return server.takeRequest(1, TimeUnit.SECONDS); return server.takeRequest(5, TimeUnit.SECONDS);
} catch (InterruptedException e) { } catch (InterruptedException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }