Skip to content

Commit

Permalink
Merge branch '3.3.x'
Browse files Browse the repository at this point in the history
Closes gh-42389
  • Loading branch information
wilkinsona committed Sep 19, 2024
2 parents d380ada + d86160d commit ba0ef11
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ void beforeEach() {

@Override
BytesMessageSender createSender() {
return createSender(Encoding.JSON, Duration.ofSeconds(10));
return createSender(Encoding.JSON, Duration.ofMinutes(1));
}

ZipkinWebClientSender createSender(Encoding encoding, Duration timeout) {
Expand Down Expand Up @@ -110,7 +110,7 @@ void sendShouldSendSpansToZipkin() throws IOException, InterruptedException {
void sendShouldSendSpansToZipkinInProto3() throws IOException, InterruptedException {
mockBackEnd.enqueue(new MockResponse());
List<byte[]> encodedSpans = List.of(toByteArray("span1"), toByteArray("span2"));
try (BytesMessageSender sender = createSender(Encoding.PROTO3, Duration.ofSeconds(10))) {
try (BytesMessageSender sender = createSender(Encoding.PROTO3, Duration.ofMinutes(1))) {
sender.send(encodedSpans);
}
requestAssertions((request) -> {
Expand All @@ -126,7 +126,7 @@ void sendUsesDynamicEndpoint() throws Exception {
mockBackEnd.enqueue(new MockResponse());
try (HttpEndpointSupplier httpEndpointSupplier = new TestHttpEndpointSupplier(ZIPKIN_URL)) {
try (BytesMessageSender sender = createSender((endpoint) -> httpEndpointSupplier, Encoding.JSON,
Duration.ofSeconds(10))) {
Duration.ofMinutes(1))) {
sender.send(Collections.emptyList());
sender.send(Collections.emptyList());
}
Expand Down

0 comments on commit ba0ef11

Please sign in to comment.