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 index 96eaed92..a5479099 100644 --- 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 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); + } }