diff --git a/exporters/sender/okhttp/src/test/java/io/opentelemetry/exporter/sender/okhttp/internal/OkHttpGrpcSenderTest.java b/exporters/sender/okhttp/src/test/java/io/opentelemetry/exporter/sender/okhttp/internal/OkHttpGrpcSenderTest.java index b5b99877cb2..63a69ffabe4 100644 --- a/exporters/sender/okhttp/src/test/java/io/opentelemetry/exporter/sender/okhttp/internal/OkHttpGrpcSenderTest.java +++ b/exporters/sender/okhttp/src/test/java/io/opentelemetry/exporter/sender/okhttp/internal/OkHttpGrpcSenderTest.java @@ -88,6 +88,7 @@ void send_rejectedExecution_callsOnError() { sender.send(new TestMessageWriter(), responseRef::set, errorRef::set); assertThat(errorRef.get()).isNotNull(); + assertThat(errorRef.get()).hasMessageContaining("executor rejected"); assertThat(responseRef.get()).isNull(); } diff --git a/exporters/sender/okhttp/src/test/java/io/opentelemetry/exporter/sender/okhttp/internal/OkHttpHttpSenderTest.java b/exporters/sender/okhttp/src/test/java/io/opentelemetry/exporter/sender/okhttp/internal/OkHttpHttpSenderTest.java index 251b85ca63a..994e9a99985 100644 --- a/exporters/sender/okhttp/src/test/java/io/opentelemetry/exporter/sender/okhttp/internal/OkHttpHttpSenderTest.java +++ b/exporters/sender/okhttp/src/test/java/io/opentelemetry/exporter/sender/okhttp/internal/OkHttpHttpSenderTest.java @@ -75,6 +75,7 @@ void send_rejectedExecution_callsOnError() { sender.send(new NoOpRequestBodyWriter(), responseRef::set, errorRef::set); assertThat(errorRef.get()).isNotNull(); + assertThat(errorRef.get()).hasMessageContaining("executor rejected"); assertThat(responseRef.get()).isNull(); }