Support eventuate-foundation/eventuate-common#118

eventuate-foundation · Oct 3, 2022 · 805dcf5 · 805dcf5
1 parent 1f15614
commit 805dcf5
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 11 deletions.
diff --git a/docker-compose-mysql.yml b/docker-compose-mysql.yml
@@ -1,7 +1,7 @@
 version: '3'
 services:
   mysql:
-    image: eventuateio/eventuate-mysql:$EVENTUATE_COMMON_VERSION
+    image: eventuateio/eventuate-mysql8:$EVENTUATE_COMMON_VERSION
     ports:
       - 3306:3306
     environment:

diff --git a/docker-compose-zookeeper.yml b/docker-compose-zookeeper.yml
@@ -1,6 +1,6 @@
 version: '3'
 services:
   zookeeper:
-    image: confluentinc/cp-zookeeper:5.2.4
+    image: eventuateio/eventuate-zookeeper:$EVENTUATE_COMMON_VERSION
     ports:
       - 2181:2181
diff --git a/...ain/java/io/eventuate/common/quarkus/jdbc/EventuateCommonJdbcOperationsConfiguration.java b/...ain/java/io/eventuate/common/quarkus/jdbc/EventuateCommonJdbcOperationsConfiguration.java
@@ -1,13 +1,9 @@
 package io.eventuate.common.quarkus.jdbc;
 
-import io.eventuate.common.jdbc.EventuateCommonJdbcOperations;
-import io.eventuate.common.jdbc.EventuateCommonJdbcStatementExecutor;
-import io.eventuate.common.jdbc.EventuateJdbcOperationsUtils;
-import io.eventuate.common.jdbc.EventuateJdbcStatementExecutor;
-import io.eventuate.common.jdbc.EventuateSqlException;
-import io.eventuate.common.jdbc.EventuateTransactionTemplate;
+import io.eventuate.common.jdbc.*;
 import io.eventuate.common.jdbc.sqldialect.EventuateSqlDialect;
 import io.eventuate.common.jdbc.sqldialect.SqlDialectSelector;
+import io.quarkus.arc.DefaultBean;
 import org.eclipse.microprofile.config.inject.ConfigProperty;
 
 import javax.enterprise.inject.Instance;
@@ -19,14 +15,21 @@
 @Singleton
 public class EventuateCommonJdbcOperationsConfiguration {
 
+  @Singleton
+  @DefaultBean
+  public OutboxPartitioningSpec outboxPartitioningSpec() {
+    return OutboxPartitioningSpec.DEFAULT;
+  }
+
   @Singleton
   public EventuateCommonJdbcOperations eventuateCommonJdbcOperations(EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor,
                                                                      SqlDialectSelector sqlDialectSelector,
-                                                                     @ConfigProperty(name = "eventuateDatabase") String dbName) {
+                                                                     @ConfigProperty(name = "eventuateDatabase") String dbName,
+                                                                     OutboxPartitioningSpec outboxPartitioningSpec) {
 
     EventuateSqlDialect eventuateSqlDialect = sqlDialectSelector.getDialect(dbName, Optional.empty());
 
-    return new EventuateCommonJdbcOperations(new EventuateJdbcOperationsUtils(eventuateSqlDialect), eventuateJdbcStatementExecutor, eventuateSqlDialect);
+    return new EventuateCommonJdbcOperations(new EventuateJdbcOperationsUtils(eventuateSqlDialect), eventuateJdbcStatementExecutor, eventuateSqlDialect, outboxPartitioningSpec);
   }
 
   @Singleton

diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties
@@ -3,5 +3,5 @@ distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-6.8.3-all.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-6.9.1-all.zip