|
10 | 10 | import io.opentelemetry.api.trace.StatusCode; |
11 | 11 | import io.opentelemetry.sdk.trace.ReadableSpan; |
12 | 12 | import org.junit.jupiter.api.Assertions; |
| 13 | +import org.junit.jupiter.api.Assumptions; |
13 | 14 | import org.junit.jupiter.api.Test; |
14 | 15 | import org.junit.jupiter.api.Timeout; |
15 | 16 |
|
16 | | -import java.util.Arrays; |
17 | | -import java.util.Collections; |
18 | | -import java.util.List; |
19 | | -import java.util.UUID; |
| 17 | +import java.util.*; |
20 | 18 | import java.util.concurrent.CountDownLatch; |
21 | 19 | import java.util.concurrent.ExecutionException; |
22 | 20 | import java.util.concurrent.TimeUnit; |
@@ -299,6 +297,14 @@ public void onEvent(Subscription subscription, ResolvedEvent event) { |
299 | 297 | @Test |
300 | 298 | default void testMultiStreamAppendIsInstrumentedWithTracingAsExpected() throws Throwable { |
301 | 299 | KurrentDBClient client = getDefaultClient(); |
| 300 | + |
| 301 | + Optional<ServerVersion> version = client.getServerVersion().get(); |
| 302 | + |
| 303 | + Assumptions.assumeTrue( |
| 304 | + version.isPresent() && version.get().isGreaterOrEqualThan(25, 0), |
| 305 | + "Multi-stream append is not supported server versions below 25.0.0" |
| 306 | + ); |
| 307 | + |
302 | 308 | String streamName1 = generateName(); |
303 | 309 | String streamName2 = generateName(); |
304 | 310 |
|
@@ -352,6 +358,14 @@ default void testMultiStreamAppendIsInstrumentedWithTracingAsExpected() throws T |
352 | 358 | @Test |
353 | 359 | default void testMultiStreamAppendIsInstrumentedWithFailures() throws Throwable { |
354 | 360 | KurrentDBClient client = getDefaultClient(); |
| 361 | + |
| 362 | + Optional<ServerVersion> version = client.getServerVersion().get(); |
| 363 | + |
| 364 | + Assumptions.assumeTrue( |
| 365 | + version.isPresent() && version.get().isGreaterOrEqualThan(25, 0), |
| 366 | + "Multi-stream append is not supported server versions below 25.0.0" |
| 367 | + ); |
| 368 | + |
355 | 369 | String streamName1 = generateName(); |
356 | 370 | String streamName2 = generateName(); |
357 | 371 |
|
|
0 commit comments