use spring data domain event.

Author: yuanxuegui

src/main/java/org/springframework/data/ebean/domain/AbstractEntity.java

@@ -16,10 +16,17 @@
 
 package org.springframework.data.ebean.domain;
 
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.List;
 import javax.persistence.Id;
 import javax.persistence.MappedSuperclass;
 import javax.persistence.Transient;
+import org.springframework.data.domain.AfterDomainEventPublication;
+import org.springframework.data.domain.DomainEvents;
 import org.springframework.data.domain.Persistable;
+import org.springframework.util.Assert;
 import org.springframework.util.ClassUtils;
 
 /**
@@ -32,10 +39,43 @@
 public abstract class AbstractEntity implements Persistable<Long> {
 
   private static final long serialVersionUID = -5554308939380869754L;
-
+  @Transient
+  private transient final @org.springframework.data.annotation.Transient
+  List<Object> domainEvents = new ArrayList<>();
   @Id
   protected Long id;
 
+  /**
+   * Registers the given event object for publication on a call to a Spring Data repository's save methods.
+   *
+   * @param event must not be {@literal null}.
+   * @return the event that has been added.
+   */
+  protected <T> T registerEvent(T event) {
+
+    Assert.notNull(event, "Domain event must not be null!");
+
+    this.domainEvents.add(event);
+    return event;
+  }
+
+  /**
+   * Clears all domain events currently held. Usually invoked by the infrastructure in place in Spring Data
+   * repositories.
+   */
+  @AfterDomainEventPublication
+  protected void clearDomainEvents() {
+    this.domainEvents.clear();
+  }
+
+  /**
+   * All domain events currently captured by the aggregate.
+   */
+  @DomainEvents
+  protected Collection<Object> domainEvents() {
+    return Collections.unmodifiableList(domainEvents);
+  }
+
   /*
    * (non-Javadoc)
    *

src/main/java/org/springframework/data/ebean/domain/AggregateRoot.java

@@ -19,5 +19,5 @@
    * Get the String representation of the aggregate's type. Optional. This defaults to the simple name of the
    * annotated class.
    */
-  String type() default "";
+  String value() default "";
 }

src/main/java/org/springframework/data/ebean/domain/DomainEvent.java

@@ -1,17 +1,15 @@
 package org.springframework.data.ebean.domain;
 
-import java.util.Date;
+import org.springframework.context.ApplicationEvent;
 
 /**
- * DomainEvent interface.
- *
+ * Domain event.
  * @author Xuegui Yuan
  */
-public interface DomainEvent {
-  /**
-   * Occurred date.
-   *
-   * @return Occurred date
-   */
-  Date occurredOn();
-}
+public class DomainEvent extends ApplicationEvent {
+
+  public DomainEvent(Object source) {
+    super(source);
+  }
+
+}

src/main/java/org/springframework/data/ebean/domain/DomainEventPublisher.java

@@ -11,6 +11,7 @@
 import org.springframework.context.annotation.Primary;
 import org.springframework.data.ebean.querychannel.EbeanQueryChannelService;
 import org.springframework.data.ebean.repository.config.EnableEbeanRepositories;
+import org.springframework.data.ebean.sample.domain.UserDomainService;
 import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
 import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType;
@@ -70,4 +71,9 @@ public DataSource dataSource() {
   public EbeanServer defaultEbeanServer(ServerConfig defaultEbeanServerConfig) {
     return EbeanServerFactory.create(defaultEbeanServerConfig);
   }
+
+  @Bean
+  public UserDomainService userDomainService() {
+    return new UserDomainService();
+  }
 }

src/test/java/org/springframework/data/ebean/sample/config/SampleConfig.java

@@ -34,13 +34,15 @@
 import lombok.Getter;
 import lombok.Setter;
 import org.springframework.data.ebean.domain.AbstractAuditableEntity;
+import org.springframework.data.ebean.domain.AggregateRoot;
 
 /**
  * Domain class representing a person emphasizing the use of {@code AbstractEntity}. No declaration of an id is
  * required. The id is typed by the parameterizable superclass.
  *
  * @author Xuegui Yuan
  */
+@AggregateRoot
 @Entity
 @Table(name = "user")
 @Getter
@@ -102,6 +104,8 @@ public User(String firstName, String lastName, String emailAddress, Role... role
 
     public void changeEmail(String emailAddress) {
         this.emailAddress = emailAddress;
+        UserEmailChangedEvent emailChangedEvent = new UserEmailChangedEvent(this);
+        this.registerEvent(emailChangedEvent);
     }
 
     /**

src/test/java/org/springframework/data/ebean/sample/domain/User.java

@@ -0,0 +1,19 @@
+package org.springframework.data.ebean.sample.domain;
+
+import org.springframework.data.ebean.domain.DomainService;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+/**
+ * @author Xuegui Yuan
+ */
+@DomainService
+public class UserDomainService {
+
+  @Async
+  @TransactionalEventListener
+  public UserEmailChangedEvent handleUserEmailChanged(UserEmailChangedEvent emailChangedEvent) {
+    System.out.println("UserEmailChangedEvent:" + emailChangedEvent.getSource());
+    return null;
+  }
+}

src/test/java/org/springframework/data/ebean/sample/domain/UserDomainService.java

@@ -1,22 +1,14 @@
 package org.springframework.data.ebean.sample.domain;
 
-import java.util.Date;
-import lombok.AllArgsConstructor;
 import lombok.Data;
 import org.springframework.data.ebean.domain.DomainEvent;
 
 /**
  * @author Xuegui Yuan
  */
 @Data
-@AllArgsConstructor
-public class UserEmailChangedEvent implements DomainEvent {
-    private Long userId;
-    private String email;
-    private Date createdTime;
-
-    @Override
-    public Date occurredOn() {
-        return createdTime;
+public class UserEmailChangedEvent extends DomainEvent {
+    public UserEmailChangedEvent(Object source) {
+        super(source);
     }
 }