diff --git a/java/integTest/src/test/java/glide/TransactionTestUtilities.java b/java/integTest/src/test/java/glide/TransactionTestUtilities.java index ef84438630..0f6c8ff4e3 100644 --- a/java/integTest/src/test/java/glide/TransactionTestUtilities.java +++ b/java/integTest/src/test/java/glide/TransactionTestUtilities.java @@ -5,6 +5,7 @@ import glide.api.models.BaseTransaction; import glide.api.models.commands.SetOptions; +import glide.api.models.commands.StreamAddOptions; import java.util.Map; import java.util.Set; import java.util.UUID; @@ -18,6 +19,7 @@ public class TransactionTestUtilities { private static final String key6 = "{key}" + UUID.randomUUID(); private static final String key7 = "{key}" + UUID.randomUUID(); private static final String key8 = "{key}" + UUID.randomUUID(); + private static final String key9 = "{key}" + UUID.randomUUID(); private static final String value1 = UUID.randomUUID().toString(); private static final String value2 = UUID.randomUUID().toString(); private static final String value3 = UUID.randomUUID().toString(); @@ -91,6 +93,10 @@ public static BaseTransaction transactionTest(BaseTransaction baseTransact baseTransaction.zscore(key8, "two"); baseTransaction.zpopmax(key8); + baseTransaction.xadd(key9, Map.of("field1", "value1"), StreamAddOptions.builder().id("0-1").build()); + baseTransaction.xadd(key9, Map.of("field2", "value2"), StreamAddOptions.builder().id("0-2").build()); + baseTransaction.xadd(key9, Map.of("field3", "value3"), StreamAddOptions.builder().id("0-3").build()); + baseTransaction.configSet(Map.of("timeout", "1000")); baseTransaction.configGet(new String[] {"timeout"}); @@ -151,6 +157,9 @@ public static Object[] transactionTestResult() { 2L, 2.0, // zscore(key8, "two") Map.of("three", 3.0), // zpopmax(key8) + "0-1", // xadd(key9, Map.of("field1", "value1"), StreamAddOptions.builder().id("0-1").build()); + "0-2", // xadd(key9, Map.of("field2", "value2"), StreamAddOptions.builder().id("0-2").build()); + "0-3", // xadd(key9, Map.of("field3", "value3"), StreamAddOptions.builder().id("0-3").build()); OK, Map.of("timeout", "1000"), OK,