Release/v1.3.0

build.gradle

@@ -0,0 +1,17 @@
+plugins {
+    id 'com.vanniktech.maven.publish' version '0.34.0' apply false
+}
+
+subprojects {
+
+    apply plugin: 'java-library'
+    apply plugin: 'com.vanniktech.maven.publish'
+
+    group = 'test'
+    version = '1.0'
+
+    mavenPublishing {
+        publishToMavenCentral(true)
+        signAllPublications()
+    }
+}

core/build.gradle

@@ -9,7 +9,7 @@ compileJava {
 }
 
 group = 'com.p14n'
-version = '1.2.0-SNAPSHOT'
+version = '1.3.1-SNAPSHOT'
 
 repositories {
     mavenCentral()
@@ -88,4 +88,32 @@ configurations {
 
 artifacts {
     tests testJar
-}
+}
+
+mavenPublishing {
+
+  pom {
+    name = "Postevent Core"
+    description = 'A reliable event publishing and consumption system using PostgreSQL'
+    inceptionYear = "2025"
+    url = "https://github.com/p14n/postevent/"
+    licenses {
+      license {
+        name = 'MIT License'
+        url = 'https://opensource.org/licenses/MIT'
+      }
+    }
+    developers {
+      developer {
+       id = 'p14n'
+       name = 'Dean Chapman'
+       email = 'dean@p14n.com'
+      }
+    }
+    scm {
+      connection = 'scm:git:git://github.com/p14n/postevent.git'
+      developerConnection = 'scm:git:ssh://github.com:p14n/postevent.git'
+      url = 'https://github.com/p14n/postevent'
+    }
+  }
+}

debezium/build.gradle

@@ -9,15 +9,15 @@ compileJava {
 }
 
 group = 'com.p14n'
-version = '1.2.0-SNAPSHOT'
+version = '1.3.1-SNAPSHOT'
 
 repositories {
     mavenCentral()
 }
 
 dependencies {
     // Dependency on core module
-    implementation project(':core')
+    implementation project(':postevent-core')
 
     // Debezium dependencies
     implementation 'io.debezium:debezium-api:3.0.1.Final'
@@ -90,3 +90,31 @@ jar {
 tasks.withType(Jar) {
    duplicatesStrategy = DuplicatesStrategy.EXCLUDE
 }
+
+mavenPublishing {
+
+  pom {
+    name = "Postevent Debezium"
+    description = 'A reliable event publishing and consumption system using PostgreSQL and Debezium'
+    inceptionYear = "2025"
+    url = "https://github.com/p14n/postevent/"
+    licenses {
+      license {
+        name = 'MIT License'
+        url = 'https://opensource.org/licenses/MIT'
+      }
+    }
+    developers {
+      developer {
+       id = 'p14n'
+       name = 'Dean Chapman'
+       email = 'dean@p14n.com'
+      }
+    }
+    scm {
+      connection = 'scm:git:git://github.com/p14n/postevent.git'
+      developerConnection = 'scm:git:ssh://github.com:p14n/postevent.git'
+      url = 'https://github.com/p14n/postevent'
+    }
+  }
+}

grpc/build.gradle

@@ -1,12 +1,12 @@
-import com.vanniktech.maven.publish.SonatypeHost
-import com.vanniktech.maven.publish.JavaLibrary
-import com.vanniktech.maven.publish.JavadocJar
+//import com.vanniktech.maven.publish.SonatypeHost
+//import com.vanniktech.maven.publish.JavaLibrary
+//import com.vanniktech.maven.publish.JavadocJar
 
 plugins {
     id 'java'
     id 'com.adarshr.test-logger' version '4.0.0'
     id 'com.google.protobuf' version '0.9.2'
-    id "com.vanniktech.maven.publish" version "0.31.0"
+   // id "com.vanniktech.maven.publish" version "0.31.0"
 }
 
 compileJava {
@@ -15,16 +15,16 @@ compileJava {
 }
 
 group = 'com.p14n'
-version = '1.2.0-SNAPSHOT'
+version = '1.3.1-SNAPSHOT'
 
 repositories {
     mavenCentral()
 }
 
 dependencies {
     // Dependency on core module
-    implementation project(':core')
-    implementation project(':debezium')
+    implementation project(':postevent-core')
+    implementation project(':postevent-debezium')
 
     // gRPC dependencies
     implementation 'io.grpc:grpc-netty-shaded:1.53.0'
@@ -49,7 +49,7 @@ dependencies {
     implementation 'io.opentelemetry.instrumentation:opentelemetry-grpc-1.6:1.32.0-alpha'
 
     // Test dependencies
-    testImplementation project(path: ':core', configuration: 'tests')
+    testImplementation project(path: ':postevent-core', configuration: 'tests')
     testImplementation 'net.jqwik:jqwik:1.8.2'
     testImplementation platform('io.zonky.test.postgres:embedded-postgres-binaries-bom:16.2.0')
     testImplementation 'io.zonky.test:embedded-postgres:2.0.7'
@@ -136,18 +136,10 @@ javadoc {
 }
 
 mavenPublishing {
-
-  configure(new JavaLibrary(new JavadocJar.Javadoc(), true))
 
-  publishToMavenCentral(SonatypeHost.CENTRAL_PORTAL, true)
-
-  signAllPublications()
-
-  coordinates("com.p14n", "postevent", version)
-
   pom {
-    name = "Postevent"
-    description = 'A reliable event publishing and consumption system using PostgreSQL and gRPC'
+    name = "Postevent gRPC"
+    description = 'A reliable event publishing and consumption system using PostgreSQL, Debezium and gRPC'
     inceptionYear = "2025"
     url = "https://github.com/p14n/postevent/"
     licenses {
@@ -169,4 +161,4 @@ mavenPublishing {
       url = 'https://github.com/p14n/postevent'
     }
   }
-}
+}

settings.gradle

@@ -1,2 +1,6 @@
 rootProject.name = 'postevent'
-include 'core', 'debezium', 'grpc', 'vertx', 'app'
+include 'core', 'debezium', 'grpc', 'vertx'
+project(':core').name = 'postevent-core'
+project(':debezium').name = 'postevent-debezium'
+project(':grpc').name = 'postevent-grpc'
+project(':vertx').name = 'postevent-vertx'

vertx/build.gradle

@@ -1,6 +1,12 @@
+
+//import com.vanniktech.maven.publish.SonatypeHost
+//import com.vanniktech.maven.publish.JavaLibrary
+//import com.vanniktech.maven.publish.JavadocJar
+
 plugins {
     id 'java'
     id 'com.adarshr.test-logger' version '4.0.0'
+    //id "com.vanniktech.maven.publish" version "0.31.0"
 }
 
 compileJava {
@@ -9,15 +15,16 @@ compileJava {
 }
 
 group = 'com.p14n'
-version = '1.2.0-SNAPSHOT'
+version = '1.3.1-SNAPSHOT'
+
 
 repositories {
     mavenCentral()
 }
 
 dependencies {
     // Dependency on core module
-    implementation project(':core')
+    implementation project(':postevent-core')
 
     // Vert.x dependencies
     implementation 'io.vertx:vertx-core:5.0.4'
@@ -79,19 +86,12 @@ tasks.withType(Jar) {
    duplicatesStrategy = DuplicatesStrategy.EXCLUDE
 }
 
-mavenPublishing {
-
-  configure(new JavaLibrary(new JavadocJar.Javadoc(), true))
 
-  publishToMavenCentral(SonatypeHost.CENTRAL_PORTAL, true)
-
-  signAllPublications()
+mavenPublishing {
 
-  coordinates("com.p14n", "postevent-vertx", version)
-
   pom {
     name = "Postevent Vert.x"
-    description = 'A reliable event publishing and consumption system using PostgreSQL and vert.x'
+    description = 'A reliable event publishing and consumption system using PostgreSQL and Vert.x EventBus'
     inceptionYear = "2025"
     url = "https://github.com/p14n/postevent/"
     licenses {
@@ -113,4 +113,4 @@ mavenPublishing {
       url = 'https://github.com/p14n/postevent'
     }
   }
-}
+}

vertx/src/main/java/com/p14n/postevent/vertx/VertxConsumerServer.java

@@ -15,28 +15,53 @@
 import java.util.List;
 import java.util.Set;
 
+/**
+ * Vert.x-based consumer server that provides event consumption capabilities
+ * using the EventBus for communication and coordination.
+ *
+ * <p>
+ * This server sets up the necessary infrastructure for event processing
+ * including database setup, message brokers, and catchup services.
+ * </p>
+ */
 public class VertxConsumerServer implements AutoCloseable {
     private static final Logger logger = LoggerFactory.getLogger(VertxConsumerServer.class);
 
-    private DataSource ds;
-    //private ConfigData cfg;
+    private final DataSource ds;
     private List<AutoCloseable> closeables;
-    private AsyncExecutor asyncExecutor;
+    private final AsyncExecutor asyncExecutor;
     OpenTelemetry ot;
 
+    /**
+     * Creates a new VertxConsumerServer.
+     *
+     * @param ds            The DataSource for database operations
+     * @param asyncExecutor The async executor for handling operations
+     * @param ot            The OpenTelemetry instance for observability
+     */
     public VertxConsumerServer(DataSource ds, AsyncExecutor asyncExecutor, OpenTelemetry ot) {
         this.ds = ds;
         this.asyncExecutor = asyncExecutor;
         this.ot = ot;
     }
 
-    public void start(EventBus eb, EventBusMessageBroker mb, Set<String> topics) throws IOException, InterruptedException {
+    /**
+     * Starts the consumer server with the specified configuration.
+     *
+     * @param eb     The Vert.x EventBus to use for communication
+     * @param mb     The EventBus message broker for event handling
+     * @param topics The set of topics to handle
+     * @throws IOException          If database setup fails
+     * @throws InterruptedException If the operation is interrupted
+     */
+    public void start(EventBus eb, EventBusMessageBroker mb, Set<String> topics)
+            throws IOException, InterruptedException {
         logger.atInfo().log("Starting consumer server");
 
         var db = new DatabaseSetup(ds);
         db.setupServer(topics);
         var catchupServer = new CatchupServer(ds);
-        var catchupService = new EventBusCatchupService(catchupServer,eb,topics,this.asyncExecutor);
+        var catchupService = new EventBusCatchupService(catchupServer, eb, topics, this.asyncExecutor);
 
         closeables = List.of(catchupService, mb, asyncExecutor);
         System.out.println("🌐 Vert.x EventBus server started");
@@ -45,11 +70,11 @@ public void start(EventBus eb, EventBusMessageBroker mb, Set<String> topics) thr
 
     @Override
     public void close() {
-        if(closeables != null){
-            for(var c : closeables){
+        if (closeables != null) {
+            for (var c : closeables) {
                 try {
                     c.close();
-                } catch (Exception e){
+                } catch (Exception e) {
 
                 }
             }