diff --git a/pom.xml b/pom.xml
index b230bbb69e..ef63359507 100644
--- a/pom.xml
+++ b/pom.xml
@@ -5,7 +5,7 @@
org.springframework.data
spring-data-relational-parent
- 2.2.0-SNAPSHOT
+ 2.2.0-gh-910-SNAPSHOT
pom
Spring Data Relational Parent
diff --git a/spring-data-jdbc-distribution/pom.xml b/spring-data-jdbc-distribution/pom.xml
index a922ef00a2..58685fb13e 100644
--- a/spring-data-jdbc-distribution/pom.xml
+++ b/spring-data-jdbc-distribution/pom.xml
@@ -14,7 +14,7 @@
org.springframework.data
spring-data-relational-parent
- 2.2.0-SNAPSHOT
+ 2.2.0-gh-910-SNAPSHOT
../pom.xml
diff --git a/spring-data-jdbc/pom.xml b/spring-data-jdbc/pom.xml
index 6f04d6b4b0..27be96e253 100644
--- a/spring-data-jdbc/pom.xml
+++ b/spring-data-jdbc/pom.xml
@@ -6,7 +6,7 @@
4.0.0
spring-data-jdbc
- 2.2.0-SNAPSHOT
+ 2.2.0-gh-910-SNAPSHOT
Spring Data JDBC
Spring Data module for JDBC repositories.
@@ -15,7 +15,7 @@
org.springframework.data
spring-data-relational-parent
- 2.2.0-SNAPSHOT
+ 2.2.0-gh-910-SNAPSHOT
diff --git a/spring-data-jdbc/src/main/java/org/springframework/data/jdbc/core/JdbcAggregateTemplate.java b/spring-data-jdbc/src/main/java/org/springframework/data/jdbc/core/JdbcAggregateTemplate.java
index 2826332979..6755d8a364 100644
--- a/spring-data-jdbc/src/main/java/org/springframework/data/jdbc/core/JdbcAggregateTemplate.java
+++ b/spring-data-jdbc/src/main/java/org/springframework/data/jdbc/core/JdbcAggregateTemplate.java
@@ -404,6 +404,9 @@ private T triggerAfterLoad(T entity) {
}
private T triggerBeforeConvert(T aggregateRoot) {
+
+ publisher.publishEvent(new BeforeConvertEvent<>(aggregateRoot));
+
return entityCallbacks.callback(BeforeConvertCallback.class, aggregateRoot);
}
diff --git a/spring-data-jdbc/src/test/java/org/springframework/data/jdbc/repository/SimpleJdbcRepositoryEventsUnitTests.java b/spring-data-jdbc/src/test/java/org/springframework/data/jdbc/repository/SimpleJdbcRepositoryEventsUnitTests.java
index 61564f8c33..671eb161f9 100644
--- a/spring-data-jdbc/src/test/java/org/springframework/data/jdbc/repository/SimpleJdbcRepositoryEventsUnitTests.java
+++ b/spring-data-jdbc/src/test/java/org/springframework/data/jdbc/repository/SimpleJdbcRepositoryEventsUnitTests.java
@@ -54,6 +54,7 @@
import org.springframework.data.relational.core.mapping.event.AfterDeleteEvent;
import org.springframework.data.relational.core.mapping.event.AfterLoadEvent;
import org.springframework.data.relational.core.mapping.event.AfterSaveEvent;
+import org.springframework.data.relational.core.mapping.event.BeforeConvertEvent;
import org.springframework.data.relational.core.mapping.event.BeforeDeleteEvent;
import org.springframework.data.relational.core.mapping.event.BeforeSaveEvent;
import org.springframework.data.relational.core.mapping.event.Identifier;
@@ -115,6 +116,7 @@ public void publishesEventsOnSave() {
assertThat(publisher.events) //
.extracting(e -> (Class) e.getClass()) //
.containsExactly( //
+ BeforeConvertEvent.class, //
BeforeSaveEvent.class, //
AfterSaveEvent.class //
);
@@ -132,8 +134,10 @@ public void publishesEventsOnSaveMany() {
assertThat(publisher.events) //
.extracting(e -> (Class) e.getClass()) //
.containsExactly( //
+ BeforeConvertEvent.class, //
BeforeSaveEvent.class, //
AfterSaveEvent.class, //
+ BeforeConvertEvent.class, //
BeforeSaveEvent.class, //
AfterSaveEvent.class //
);
diff --git a/spring-data-relational/pom.xml b/spring-data-relational/pom.xml
index 6b2507aabe..5742d7f7ec 100644
--- a/spring-data-relational/pom.xml
+++ b/spring-data-relational/pom.xml
@@ -6,7 +6,7 @@
4.0.0
spring-data-relational
- 2.2.0-SNAPSHOT
+ 2.2.0-gh-910-SNAPSHOT
Spring Data Relational
Spring Data Relational support
@@ -14,7 +14,7 @@
org.springframework.data
spring-data-relational-parent
- 2.2.0-SNAPSHOT
+ 2.2.0-gh-910-SNAPSHOT
diff --git a/spring-data-relational/src/main/java/org/springframework/data/relational/core/mapping/event/BeforeConvertEvent.java b/spring-data-relational/src/main/java/org/springframework/data/relational/core/mapping/event/BeforeConvertEvent.java
index 12615cd8e2..807ab5bb7f 100644
--- a/spring-data-relational/src/main/java/org/springframework/data/relational/core/mapping/event/BeforeConvertEvent.java
+++ b/spring-data-relational/src/main/java/org/springframework/data/relational/core/mapping/event/BeforeConvertEvent.java
@@ -23,7 +23,7 @@
* @since 1.1
* @author Jens Schauder
*/
-public class BeforeConvertEvent extends RelationalSaveEvent {
+public class BeforeConvertEvent extends RelationalEventWithEntity {
private static final long serialVersionUID = -5716795164911939224L;
@@ -33,7 +33,7 @@ public class BeforeConvertEvent extends RelationalSaveEvent {
* this event is fired before the conversion the change is actually empty, but contains information if the
* aggregate is considered new in {@link AggregateChange#getKind()}. Must not be {@literal null}.
*/
- public BeforeConvertEvent(E instance, AggregateChange change) {
- super(instance, change);
+ public BeforeConvertEvent(E instance) {
+ super(instance);
}
}
diff --git a/spring-data-relational/src/test/java/org/springframework/data/relational/core/mapping/event/AbstractRelationalEventListenerUnitTests.java b/spring-data-relational/src/test/java/org/springframework/data/relational/core/mapping/event/AbstractRelationalEventListenerUnitTests.java
index 5e1c554e71..b242965a21 100644
--- a/spring-data-relational/src/test/java/org/springframework/data/relational/core/mapping/event/AbstractRelationalEventListenerUnitTests.java
+++ b/spring-data-relational/src/test/java/org/springframework/data/relational/core/mapping/event/AbstractRelationalEventListenerUnitTests.java
@@ -46,7 +46,7 @@ public void afterLoad() {
@Test // DATAJDBC-454
public void beforeConvert() {
- listener.onApplicationEvent(new BeforeConvertEvent<>(dummyEntity, MutableAggregateChange.forDelete(dummyEntity)));
+ listener.onApplicationEvent(new BeforeConvertEvent<>(dummyEntity));
assertThat(events).containsExactly("beforeConvert");
}