Skip to content

Commit 86652c4

Browse files
authored
Merge pull request #1338 from nats-io/kv-limit-marker-test
Fixed KV Limit Marker Test to only run against 2.11.2 or later
2 parents f5b1042 + cf8ddd2 commit 86652c4

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

src/test/java/io/nats/client/impl/KeyValueTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1798,7 +1798,7 @@ public void testConsumeKeys() throws Exception {
17981798

17991799
@Test
18001800
public void testLimitMarker() throws Exception {
1801-
jsServer.run(TestBase::atLeast2_11, nc -> {
1801+
jsServer.run(TestBase::atLeast2_11_2, nc -> {
18021802
KeyValueManagement kvm = nc.keyValueManagement();
18031803
String bucket = bucket();
18041804
KeyValueConfiguration config = KeyValueConfiguration.builder()
@@ -1845,7 +1845,7 @@ public void testLimitMarker() throws Exception {
18451845

18461846
@Test
18471847
public void testLimitMarkerAlso() throws Exception {
1848-
jsServer.run(TestBase::atLeast2_11, nc -> {
1848+
jsServer.run(TestBase::atLeast2_11_2, nc -> {
18491849
String bucket = bucket();
18501850
String key = key();
18511851

src/test/java/io/nats/client/utils/TestBase.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,10 @@ public static boolean before2_11(ServerInfo si) {
161161
return si.isOlderThanVersion("2.11");
162162
}
163163

164+
public static boolean atLeast2_11_2(ServerInfo si) {
165+
return si.isSameOrNewerThanVersion("2.11.2");
166+
}
167+
164168
public static void runInServer(InServerTest inServerTest) throws Exception {
165169
runInServer(false, false, null, null, inServerTest);
166170
}

0 commit comments

Comments
 (0)