diff --git a/core/build.gradle b/core/build.gradle index 2d2462e..46a9e08 100644 --- a/core/build.gradle +++ b/core/build.gradle @@ -9,7 +9,7 @@ compileJava { } group = 'com.p14n' -version = '1.3.2-SNAPSHOT' +version = '1.3.3-SNAPSHOT' repositories { mavenCentral() diff --git a/debezium/build.gradle b/debezium/build.gradle index 497ec0f..ec747fd 100644 --- a/debezium/build.gradle +++ b/debezium/build.gradle @@ -9,7 +9,7 @@ compileJava { } group = 'com.p14n' -version = '1.3.2-SNAPSHOT' +version = '1.3.3-SNAPSHOT' repositories { mavenCentral() diff --git a/grpc/build.gradle b/grpc/build.gradle index 574f94f..2a0aaef 100644 --- a/grpc/build.gradle +++ b/grpc/build.gradle @@ -15,7 +15,7 @@ compileJava { } group = 'com.p14n' -version = '1.3.2-SNAPSHOT' +version = '1.3.3-SNAPSHOT' repositories { mavenCentral() @@ -32,7 +32,7 @@ dependencies { implementation 'io.grpc:grpc-stub:1.53.0' implementation 'io.grpc:grpc-api:1.53.0' - implementation 'javax.annotation:javax.annotation-api:1.3.2' + implementation 'javax.annotation:javax.annotation-api:1.3.3-SNAPSHOT' // For code generation implementation 'com.google.protobuf:protobuf-java:3.21.7' diff --git a/vertx/build.gradle b/vertx/build.gradle index 4c254dd..8ab2f20 100644 --- a/vertx/build.gradle +++ b/vertx/build.gradle @@ -15,7 +15,7 @@ compileJava { } group = 'com.p14n' -version = '1.3.2-SNAPSHOT' +version = '1.3.3-SNAPSHOT' repositories { diff --git a/vertx/src/main/java/com/p14n/postevent/vertx/adapter/EventBusMessageBroker.java b/vertx/src/main/java/com/p14n/postevent/vertx/adapter/EventBusMessageBroker.java index 6f83631..d2bb5b9 100644 --- a/vertx/src/main/java/com/p14n/postevent/vertx/adapter/EventBusMessageBroker.java +++ b/vertx/src/main/java/com/p14n/postevent/vertx/adapter/EventBusMessageBroker.java @@ -154,7 +154,7 @@ public void publish(String topic, TransactionalEvent event) { // Then, publish to EventBus for real-time distribution String eventBusAddress = "events." + topic; - eventBus.publish(eventBusAddress, event); + eventBus.publish(eventBusAddress, event.event()); logger.atDebug() .addArgument(topic)