Enhancements for eventuate-foundation/eventuate-cdc#133

eventuate-foundation · Sep 8, 2022 · 5c49601 · 5c49601
1 parent e44ea1e
commit 5c49601
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/eventuate-common-jdbc/src/main/java/io/eventuate/common/jdbc/OutboxPartitioningSpec.java b/eventuate-common-jdbc/src/main/java/io/eventuate/common/jdbc/OutboxPartitioningSpec.java
@@ -39,4 +39,12 @@ public List<String> outboxTableSuffixes() {
         else
             return IntStream.range(0, outboxTables).mapToObj(Integer::toString).collect(Collectors.toList());
     }
+
+    public OutboxPartitioningSpec withOutboxTables(int outboxTables) {
+        return new OutboxPartitioningSpec(outboxTables, this.outboxTablePartitions);
+    }
+
+    public OutboxPartitioningSpec withTablePartitions(int outboxTables) {
+        return new OutboxPartitioningSpec(this.outboxTables, outboxTablePartitions);
+    }
 }