Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history
  • Loading branch information
anton-vinogradov committed Jul 25, 2024
1 parent 532f2a2 commit 2d3d8bd
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -182,18 +182,18 @@ public void testResendConflictVersion() throws Exception {
assertTrue(GridTestUtils.waitForCondition(() -> cnsmr.events().size() == 3, 10_000, 100));

CdcEvent ev0 = cnsmr.events().get(0);
assertEquals(0, ev0.key());
assertEquals(0, ev0.value());
assertEquals(0, ev0.unwrappedKey());
assertEquals(0, ev0.unwrappedValue());
assertNull(ev0.version().otherClusterVersion());

CdcEvent ev1 = cnsmr.events().get(1);
assertEquals(0, ev1.key());
assertEquals(1, ev1.value());
assertEquals(0, ev1.unwrappedKey());
assertEquals(1, ev1.unwrappedValue());
assertEquals(conflict, ev1.version().otherClusterVersion());

CdcEvent ev2 = cnsmr.events().get(2);
assertEquals(0, ev2.key());
assertEquals(1, ev2.value());
assertEquals(0, ev2.unwrappedKey());
assertEquals(1, ev2.unwrappedValue());
assertNull(ev2.version().otherClusterVersion());
}

Expand Down

0 comments on commit 2d3d8bd

Please sign in to comment.