Initial commit
This commit is contained in:
Michael Schnell
6
.gitignore
vendored
Normal file
6
.gitignore
vendored
Normal file
@@ -0,0 +1,6 @@
|
||||
.*
|
||||
!.gitignore
|
||||
!.gitkeep
|
||||
!.mvn
|
||||
target
|
||||
*.log
|
||||
68
README.md
68
README.md
@@ -1,2 +1,68 @@
|
||||
# ddd-cqrs-4-java-example
|
||||
Minimal standalone example application that uses the ddd-4-java and cqrs-4-java libraries
|
||||
Minimal standalone example application that uses the [ddd-4-java](https://github.com/fuinorg/ddd-4-java) and [cqrs-4-java](https://github.com/fuinorg/cqrs-4-java) libraries and an [EventStore](https://eventstore.org/) to store the events (Event Sourcing).
|
||||
|
||||
## Starting the demo
|
||||
|
||||
1. Start an EventStore locally on your PC
|
||||
* You can use the [EventStore Docker Image](https://hub.docker.com/r/eventstore/eventstore/): ```docker run --name eventstore-node -p 2113:2113 -p 1113:1113 --rm eventstore/eventstore```
|
||||
* Or simply start an instance (See [Install and run Event Store](https://eventstore.org/docs/server/index.html?tabs=tabid-1) for more information)
|
||||
2. Run the [QryExampleApp](src/main/java/org/fuin/dddcqrs4jexample/qry/app/QryExampleApp.java) to make the view/read part listen to new events
|
||||
* You should see something like this on the console: ```INFO o.f.d.qry.handler.QryProjector - Create projection 'qry-person-stream' with events: [PersonCreatedEvent]```
|
||||
* If you open the event store UI (http://localhost:2113/web/index.html#/projections) you should see a projection name 'qry-person-stream'
|
||||
3. Run the [CmdExampleApp](src/main/java/org/fuin/dddcqrs4jexample/cmd/app/CmdExampleApp.java) to create a [PersonCreatedEvent](src/main/java/org/fuin/dddcqrs4jexample/shared/domain/PersonCreatedEvent.java)
|
||||
* You should see something like this on the console: ```INFO o.f.d.cmd.app.CmdExampleApp - Updated event store...```
|
||||
* There should also be an update on the 'QryExampleApp' console: ```INFO o.f.d.q.h.PersonCreatedEventHandler - Handle Person 'Peter Parker Inc.' was created```
|
||||
* If you open the event store UI (http://localhost:2113/web/index.html#/projections) and open the projection details for 'qry-person-stream' it should show 'Events processed = 1'
|
||||
4. Kill the [QryExampleApp](src/main/java/org/fuin/dddcqrs4jexample/qry/app/QryExampleApp.java)
|
||||
5. Stop the event store
|
||||
|
||||
## What is in the application?
|
||||
The application is splitted into three packages: 'shared', 'cmd' and 'qry'.
|
||||
|
||||
### shared
|
||||
Has code shared between both modules 'cmd' and 'qry'.
|
||||
|
||||
#### Sub package 'app'
|
||||
There are several configuration classes used for CDI in the [app](src/main/java/org/fuin/dddcqrs4jexample/shared/app) package
|
||||
|
||||
#### Sub package 'domain'
|
||||
There are three DDD domain model related classes
|
||||
* The [PersonId](src/main/java/org/fuin/dddcqrs4jexample/shared/domain/PersonId.java) that is the unique identifier for the [Person](/src/main/java/org/fuin/dddcqrs4jexample/cmd/domain/Person.java) aggregate (Value Object)
|
||||
* The [PersonName](src/main/java/org/fuin/dddcqrs4jexample/shared/domain/PersonName.java) that is the name for the [Person](/src/main/java/org/fuin/dddcqrs4jexample/cmd/domain/Person.java) aggregate (Value Object)
|
||||
* The [PersonCreatedEvent](src/main/java/org/fuin/dddcqrs4jexample/shared/domain/PersonCreatedEvent.java) that is fired if a new [Person](/src/main/java/org/fuin/dddcqrs4jexample/cmd/domain/Person.java) aggregate was created (Event / Value Object)
|
||||
|
||||
|
||||
### cmd
|
||||
Code for the 'command' or 'write' side of the application.
|
||||
|
||||
#### Sub package 'app'
|
||||
Contains mainly the command line application.
|
||||
* The command line application [CmdExampleApp](src/main/java/org/fuin/dddcqrs4jexample/cmd/app/CmdExampleApp.java) that creates a new [Person](/src/main/java/org/fuin/dddcqrs4jexample/cmd/domain/Person.java) aggregate and saves the state as a series of events in the [EventStore](https://eventstore.org/) (Event Sourcing).
|
||||
|
||||
#### Sub package 'domain'
|
||||
There are three DDD domain model related classes
|
||||
* The [Person](/src/main/java/org/fuin/dddcqrs4jexample/cmd/domain/Person.java) aggregate (Aggregate Root).
|
||||
* The [PersonRepository](src/main/java/org/fuin/dddcqrs4jexample/cmd/domain/PersonRepository.java) used to store the aggregate root in the event store.
|
||||
|
||||
### Package 'qry'
|
||||
Code for the 'query' or 'read' side of the application.
|
||||
|
||||
#### Sub package 'app'
|
||||
There are several configuration classes used for CDI in the [app](src/main/java/org/fuin/dddcqrs4jexample/qry/app) package and the main query application.
|
||||
|
||||
* The command line application [QryExampleApp](src/main/java/org/fuin/dddcqrs4jexample/qry/app/QryExampleApp.java) that reads events from the [EventStore](https://eventstore.org/) (Event Sourcing) and updates it's internal view model.
|
||||
* The [QryTimer](src/main/java/org/fuin/dddcqrs4jexample/qry/app/QryTimer.java) class fires an asynchronous CDI event called [QryCheckForViewUpdatesEvent](src/main/java/org/fuin/dddcqrs4jexample/qry/app/QryCheckForViewUpdatesEvent.java)
|
||||
|
||||
|
||||
#### Sub package 'domain'
|
||||
The view data will be stored in an in-memory HSQL database using JPA
|
||||
* The [QryPerson](src/main/java/org/fuin/dddcqrs4jexample/qry/domain/QryPerson.java) class is an [@javax.persistence.Entity](https://javaee.github.io/javaee-spec/javadocs/javax/persistence/Entity.html) class
|
||||
* The [QryPersonRepository](src/main/java/org/fuin/dddcqrs4jexample/qry/domain/QryPersonRepository.java) class is used for the [Apache DeltaSpike Data Module](https://deltaspike.apache.org/documentation/data.html) entity repository to simplifying the database access. (See [EntityRepository](https://deltaspike.apache.org/javadoc/1.7.2/index.html?org/apache/deltaspike/data/api/EntityRepository.html))
|
||||
|
||||
#### Sub package 'handler'
|
||||
The query side has to listen for new events. This is done by polling the Event Store every second.
|
||||
|
||||
* The [QryProjector](src/main/java/org/fuin/dddcqrs4jexample/qry/handler/QryProjector.java) receives the event issued by the [QryTimer](src/main/java/org/fuin/dddcqrs4jexample/qry/app/QryTimer.java) and starts reading a from a projection that collects all necessary events required for one view.
|
||||
* The [QryEventChunkHandler](src/main/java/org/fuin/dddcqrs4jexample/qry/handler/QryEventChunkHandler.java) is used to read all events of a single projection and dispatch them to the event handler that want to have them. It also updates the [QryPersonProjectionPosition](src/main/java/org/fuin/dddcqrs4jexample/qry/handler/QryPersonProjectionPosition.java) in the database. This is done to remember, what the last event was that was read from the event store's event stream (projection). It uses a helper class called [SimpleEventDispatcher](https://github.com/fuinorg/cqrs-4-java/blob/master/src/main/java/org/fuin/cqrs4j/SimpleEventDispatcher.java) that is aware of all known events and capable to handle the 'dispatch' operation.
|
||||
* The [PersonCreatedEventHandler](src/main/java/org/fuin/dddcqrs4jexample/qry/handler/PersonCreatedEventHandler.java) class is an example of an event handler that updates the local view database using a single event.
|
||||
|
||||
|
||||
25
logback.xml
Normal file
25
logback.xml
Normal file
@@ -0,0 +1,25 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<configuration>
|
||||
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
|
||||
<layout class="ch.qos.logback.classic.PatternLayout">
|
||||
<Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</Pattern>
|
||||
</layout>
|
||||
</appender>
|
||||
<appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
|
||||
<file>${log_path}/logback.log</file>
|
||||
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
|
||||
<fileNamePattern>logback.%d{yyyy-MM-dd}.log</fileNamePattern>
|
||||
<maxHistory>30</maxHistory>
|
||||
</rollingPolicy>
|
||||
<append>true</append>
|
||||
<layout class="ch.qos.logback.classic.PatternLayout">
|
||||
<Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</Pattern>
|
||||
</layout>
|
||||
</appender>
|
||||
<root level="WARN">
|
||||
<appender-ref ref="FILE" />
|
||||
<appender-ref ref="STDOUT" />
|
||||
</root>
|
||||
<logger name="org.fuin.dddcqrs4jexample.cmd" level="INFO" />
|
||||
<logger name="org.fuin.dddcqrs4jexample.qry" level="INFO" />
|
||||
</configuration>
|
||||
267
pom.xml
Normal file
267
pom.xml
Normal file
@@ -0,0 +1,267 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0"
|
||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<parent>
|
||||
<groupId>org.fuin</groupId>
|
||||
<artifactId>pom</artifactId>
|
||||
<version>1.6.0</version>
|
||||
</parent>
|
||||
|
||||
<artifactId>ddd-cqrs-4-java-example</artifactId>
|
||||
<version>0.1.0-SNAPSHOT</version>
|
||||
<description>Minimal standalone example application that uses the 'ddd-4-java' and 'ddd-cqrs-4-java-example' libraries</description>
|
||||
|
||||
<scm>
|
||||
<url>https://github.com/fuinorg/ddd-cqrs-4-java-example/</url>
|
||||
<connection>scm:git:git://github.com/fuinorg/ddd-cqrs-4-java-example.git</connection>
|
||||
<developerConnection>scm:git:git@github.com:fuinorg/ddd-cqrs-4-java-example.git</developerConnection>
|
||||
</scm>
|
||||
|
||||
<issueManagement>
|
||||
<system>GitHub Issues</system>
|
||||
<url>https://github.com/fuinorg/ddd-cqrs-4-java-example/issues</url>
|
||||
</issueManagement>
|
||||
|
||||
<properties>
|
||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||
<maven.compiler.source>1.8</maven.compiler.source>
|
||||
<maven.compiler.target>1.8</maven.compiler.target>
|
||||
<esc.version>0.3.1-SNAPSHOT</esc.version>
|
||||
</properties>
|
||||
|
||||
<dependencyManagement>
|
||||
|
||||
<dependencies>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.apache.deltaspike.distribution</groupId>
|
||||
<artifactId>distributions-bom</artifactId>
|
||||
<version>1.9.0</version>
|
||||
<scope>import</scope>
|
||||
<type>pom</type>
|
||||
</dependency>
|
||||
|
||||
</dependencies>
|
||||
|
||||
</dependencyManagement>
|
||||
|
||||
<dependencies>
|
||||
|
||||
<!-- Compile -->
|
||||
|
||||
<dependency>
|
||||
<groupId>org.fuin</groupId>
|
||||
<artifactId>ddd-4-java</artifactId>
|
||||
<version>0.2.1-SNAPSHOT</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.fuin</groupId>
|
||||
<artifactId>cqrs-4-java</artifactId>
|
||||
<version>0.2.1-SNAPSHOT</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.fuin.esc</groupId>
|
||||
<artifactId>esc-spi</artifactId>
|
||||
<version>${esc.version}</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.fuin.esc</groupId>
|
||||
<artifactId>esc-esjc</artifactId>
|
||||
<version>${esc.version}</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.fuin.esc</groupId>
|
||||
<artifactId>esc-eshttp</artifactId>
|
||||
<version>${esc.version}</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.apache.httpcomponents</groupId>
|
||||
<artifactId>httpasyncclient</artifactId>
|
||||
<version>4.1</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.apache.httpcomponents</groupId>
|
||||
<artifactId>httpclient</artifactId>
|
||||
<version>4.5</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.fuin</groupId>
|
||||
<artifactId>ext4logback</artifactId>
|
||||
<version>0.2.0</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>javax.validation</groupId>
|
||||
<artifactId>validation-api</artifactId>
|
||||
<version>2.0.1.Final</version>
|
||||
<optional>true</optional>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.apache.commons</groupId>
|
||||
<artifactId>commons-lang3</artifactId>
|
||||
<version>3.7</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
<artifactId>slf4j-api</artifactId>
|
||||
<version>1.7.25</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>ch.qos.logback</groupId>
|
||||
<artifactId>logback-classic</artifactId>
|
||||
<version>1.1.8</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>javax.enterprise</groupId>
|
||||
<artifactId>cdi-api</artifactId>
|
||||
<version>2.0</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.jboss.weld.se</groupId>
|
||||
<artifactId>weld-se-core</artifactId>
|
||||
<version>3.0.4.Final</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.eclipse.microprofile.config</groupId>
|
||||
<artifactId>microprofile-config-api</artifactId>
|
||||
<version>1.3</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>io.smallrye</groupId>
|
||||
<artifactId>smallrye-config</artifactId>
|
||||
<version>1.3.5</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>javax.json</groupId>
|
||||
<artifactId>javax.json-api</artifactId>
|
||||
<version>1.1.4</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.glassfish</groupId>
|
||||
<artifactId>javax.json</artifactId>
|
||||
<version>1.1.4</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.eclipse</groupId>
|
||||
<artifactId>yasson</artifactId>
|
||||
<version>1.0.3</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.apache.deltaspike.modules</groupId>
|
||||
<artifactId>deltaspike-data-module-api</artifactId>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.apache.deltaspike.modules</groupId>
|
||||
<artifactId>deltaspike-data-module-impl</artifactId>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.hibernate.validator</groupId>
|
||||
<artifactId>hibernate-validator</artifactId>
|
||||
<version>6.0.10.Final</version>
|
||||
<exclusions>
|
||||
<exclusion>
|
||||
<artifactId>jaxb-impl</artifactId>
|
||||
<groupId>com.sun.xml.bind</groupId>
|
||||
</exclusion>
|
||||
<exclusion>
|
||||
<artifactId>jaxb-api</artifactId>
|
||||
<groupId>javax.xml.bind</groupId>
|
||||
</exclusion>
|
||||
</exclusions>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.hibernate.javax.persistence</groupId>
|
||||
<artifactId>hibernate-jpa-2.1-api</artifactId>
|
||||
<version>1.0.2</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.hibernate</groupId>
|
||||
<artifactId>hibernate-entitymanager</artifactId>
|
||||
<version>5.4.2.Final</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>commons-io</groupId>
|
||||
<artifactId>commons-io</artifactId>
|
||||
<version>2.6</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.hsqldb</groupId>
|
||||
<artifactId>hsqldb</artifactId>
|
||||
<version>2.4.1</version>
|
||||
</dependency>
|
||||
|
||||
<!-- Test -->
|
||||
|
||||
<dependency>
|
||||
<groupId>org.fuin.esc</groupId>
|
||||
<artifactId>esc-mem</artifactId>
|
||||
<version>${esc.version}</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>junit</groupId>
|
||||
<artifactId>junit</artifactId>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.assertj</groupId>
|
||||
<artifactId>assertj-core</artifactId>
|
||||
<version>3.10.0</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.fuin</groupId>
|
||||
<artifactId>units4j</artifactId>
|
||||
<version>0.8.3</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>nl.jqno.equalsverifier</groupId>
|
||||
<artifactId>equalsverifier</artifactId>
|
||||
<version>2.4.6</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
</dependencies>
|
||||
|
||||
<build>
|
||||
|
||||
<plugins>
|
||||
|
||||
</plugins>
|
||||
|
||||
</build>
|
||||
|
||||
</project>
|
||||
@@ -0,0 +1,101 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.cmd.app;
|
||||
|
||||
import java.util.UUID;
|
||||
|
||||
import javax.enterprise.context.control.ActivateRequestContext;
|
||||
import javax.enterprise.inject.Instance;
|
||||
import javax.enterprise.inject.se.SeContainer;
|
||||
import javax.enterprise.inject.se.SeContainerInitializer;
|
||||
import javax.inject.Inject;
|
||||
|
||||
import org.fuin.dddcqrs4jexample.cmd.domain.Person;
|
||||
import org.fuin.dddcqrs4jexample.cmd.domain.PersonRepository;
|
||||
import org.fuin.dddcqrs4jexample.cmd.domain.PersonRepositoryFactory;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonId;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonName;
|
||||
import org.fuin.esc.api.EventStore;
|
||||
import org.fuin.ext4logback.LogbackStandalone;
|
||||
import org.fuin.ext4logback.NewLogConfigFileParams;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* Minimal example command (write) application.
|
||||
*/
|
||||
public class CmdExampleApp {
|
||||
|
||||
private static final Logger LOG = LoggerFactory.getLogger(CmdExampleApp.class);
|
||||
|
||||
@Inject
|
||||
private Instance<EventStore> eventStoreInstance;
|
||||
|
||||
/**
|
||||
* Executes the application.
|
||||
*/
|
||||
@ActivateRequestContext
|
||||
public void execute() {
|
||||
|
||||
LOG.info("Executing...");
|
||||
|
||||
try (final EventStore eventStore = eventStoreInstance.get()) {
|
||||
|
||||
final PersonId id = new PersonId(UUID.fromString("f645969a-402d-41a9-882b-d2d8000d0f43"));
|
||||
final PersonName name = new PersonName("Peter Parker Inc.");
|
||||
final Person person = new Person(id, name, (dn) -> {
|
||||
return null;
|
||||
});
|
||||
final PersonRepository repo = new PersonRepositoryFactory().create(eventStore);
|
||||
|
||||
repo.update(person);
|
||||
|
||||
LOG.info("Updated event store...");
|
||||
|
||||
} catch (final Exception ex) {
|
||||
throw new RuntimeException("Error saving person aggregate into event store", ex);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* Main entry point to the command line application.
|
||||
*
|
||||
* @param args
|
||||
* Not used.
|
||||
*/
|
||||
public static void main(final String[] args) {
|
||||
|
||||
try {
|
||||
|
||||
new LogbackStandalone().init(args, new NewLogConfigFileParams("org.fuin.dddcqrs4jexample", "logback"));
|
||||
|
||||
LOG.info("Start example");
|
||||
|
||||
try (final SeContainer container = SeContainerInitializer.newInstance().initialize()) {
|
||||
final CmdExampleApp app = container.select(CmdExampleApp.class).get();
|
||||
app.execute();
|
||||
}
|
||||
|
||||
LOG.info("Finished example");
|
||||
|
||||
System.exit(0);
|
||||
|
||||
} catch (final RuntimeException ex) {
|
||||
ex.printStackTrace(System.err);
|
||||
System.exit(1);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.cmd.app;
|
||||
|
||||
/**
|
||||
* Command application specific code.
|
||||
*/
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.cmd.basics;
|
||||
|
||||
/**
|
||||
* General helper classes used by all other 'cmd' packages.
|
||||
*/
|
||||
@@ -0,0 +1,54 @@
|
||||
package org.fuin.dddcqrs4jexample.cmd.domain;
|
||||
|
||||
import javax.validation.constraints.NotNull;
|
||||
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonId;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonName;
|
||||
import org.fuin.objects4j.common.Contract;
|
||||
|
||||
/**
|
||||
* A name that should be unique does already exist.
|
||||
*/
|
||||
public final class DuplicatePersonNameException extends Exception {
|
||||
|
||||
private static final long serialVersionUID = 1000L;
|
||||
|
||||
private PersonId personId;
|
||||
|
||||
private PersonName name;
|
||||
|
||||
/**
|
||||
* Constructor with mandatory data.
|
||||
*
|
||||
* @param personId
|
||||
* Identifier of the resource that caused the problem.
|
||||
* @param name
|
||||
* Name of the resource that caused the problem.
|
||||
*/
|
||||
public DuplicatePersonNameException(@NotNull final PersonId personId, @NotNull final PersonName name) {
|
||||
super("The name '" + name + "' already exists: " + personId.asString());
|
||||
Contract.requireArgNotNull("personId", personId);
|
||||
Contract.requireArgNotNull("name", name);
|
||||
this.personId = personId;
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the identifier of the entity that has the name.
|
||||
*
|
||||
* @return Identifier.
|
||||
*/
|
||||
public final PersonId getPersonId() {
|
||||
return personId;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the name that already exists.
|
||||
*
|
||||
* @return Name.
|
||||
*/
|
||||
public final PersonName getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
}
|
||||
101
src/main/java/org/fuin/dddcqrs4jexample/cmd/domain/Person.java
Normal file
101
src/main/java/org/fuin/dddcqrs4jexample/cmd/domain/Person.java
Normal file
@@ -0,0 +1,101 @@
|
||||
package org.fuin.dddcqrs4jexample.cmd.domain;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
import javax.validation.constraints.NotNull;
|
||||
|
||||
import org.fuin.ddd4j.ddd.AbstractAggregateRoot;
|
||||
import org.fuin.ddd4j.ddd.ApplyEvent;
|
||||
import org.fuin.ddd4j.ddd.EntityType;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonCreatedEvent;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonId;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonName;
|
||||
import org.fuin.objects4j.common.Contract;
|
||||
|
||||
/**
|
||||
* A medical practitioner most likely also holder of an accredited academic degree.
|
||||
*/
|
||||
public class Person extends AbstractAggregateRoot<PersonId> implements Serializable {
|
||||
|
||||
private static final long serialVersionUID = 1000L;
|
||||
|
||||
@NotNull
|
||||
private PersonId id;
|
||||
|
||||
@NotNull
|
||||
private PersonName name;
|
||||
|
||||
/**
|
||||
* Default constructor that is mandatory for aggregate roots.
|
||||
*/
|
||||
public Person() {
|
||||
super();
|
||||
}
|
||||
|
||||
/**
|
||||
* Constructor with all data.
|
||||
*
|
||||
* @param id
|
||||
* Unique identifier of the person.
|
||||
* @param name
|
||||
* Unique name of the person.
|
||||
* @param service
|
||||
* Service required by the method.
|
||||
*
|
||||
* @throws DuplicatePersonNameException
|
||||
* The name already exists for another person.
|
||||
*/
|
||||
public Person(@NotNull final PersonId id, @NotNull final PersonName name, final PersonService service) throws DuplicatePersonNameException {
|
||||
super();
|
||||
|
||||
// VERIFY PRECONDITIONS
|
||||
Contract.requireArgNotNull("id", id);
|
||||
Contract.requireArgNotNull("name", name);
|
||||
|
||||
// VERIFY BUSINESS RULES
|
||||
|
||||
// Rule 1: The name of the person must be unique
|
||||
final PersonId otherId = service.loadPersonIdByName(name);
|
||||
if (otherId != null) {
|
||||
throw new DuplicatePersonNameException(otherId, name);
|
||||
}
|
||||
|
||||
// CREATE EVENT
|
||||
apply(new PersonCreatedEvent(id, name));
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public PersonId getId() {
|
||||
return id;
|
||||
}
|
||||
|
||||
@Override
|
||||
public EntityType getType() {
|
||||
return PersonId.TYPE;
|
||||
}
|
||||
|
||||
@ApplyEvent
|
||||
public void applyEvent(final PersonCreatedEvent event) {
|
||||
this.id = event.getEntityId();
|
||||
this.name = event.getName();
|
||||
}
|
||||
|
||||
/**
|
||||
* Service for the constructor.
|
||||
*/
|
||||
public static interface PersonService {
|
||||
|
||||
/**
|
||||
* Loads the person's identifier for a given name.
|
||||
*
|
||||
* @param name
|
||||
* Person's name.
|
||||
*
|
||||
* @return Office identifier or {@literal null} if not found.
|
||||
*/
|
||||
public PersonId loadPersonIdByName(@NotNull PersonName name);
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,51 @@
|
||||
package org.fuin.dddcqrs4jexample.cmd.domain;
|
||||
|
||||
import javax.annotation.concurrent.NotThreadSafe;
|
||||
import javax.validation.constraints.NotNull;
|
||||
|
||||
import org.fuin.ddd4j.ddd.EntityType;
|
||||
import org.fuin.ddd4j.esrepo.EventStoreRepository;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonId;
|
||||
import org.fuin.esc.api.EventStore;
|
||||
|
||||
/**
|
||||
* Event sourced repository for storing a {@link Person} aggregate.
|
||||
*/
|
||||
@NotThreadSafe
|
||||
public class PersonRepository extends EventStoreRepository<PersonId, Person> {
|
||||
|
||||
/**
|
||||
* Constructor all mandatory data.
|
||||
*
|
||||
* @param eventStore
|
||||
* Event store.
|
||||
*/
|
||||
public PersonRepository(final EventStore eventStore) {
|
||||
super(eventStore);
|
||||
}
|
||||
|
||||
@Override
|
||||
@NotNull
|
||||
public Class<Person> getAggregateClass() {
|
||||
return Person.class;
|
||||
}
|
||||
|
||||
@Override
|
||||
@NotNull
|
||||
public EntityType getAggregateType() {
|
||||
return PersonId.TYPE;
|
||||
}
|
||||
|
||||
@Override
|
||||
@NotNull
|
||||
public Person create() {
|
||||
return new Person();
|
||||
}
|
||||
|
||||
@Override
|
||||
@NotNull
|
||||
public String getIdParamName() {
|
||||
return "personId";
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,29 @@
|
||||
package org.fuin.dddcqrs4jexample.cmd.domain;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.context.Dependent;
|
||||
import javax.enterprise.inject.Produces;
|
||||
|
||||
import org.fuin.esc.api.EventStore;
|
||||
|
||||
/**
|
||||
* CDI factory that creates an event store connection and repositories.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class PersonRepositoryFactory {
|
||||
|
||||
/**
|
||||
* Creates a repository.
|
||||
*
|
||||
* @param eventStore
|
||||
* Event store implementation.
|
||||
*
|
||||
* @return Dependent scope project repository.
|
||||
*/
|
||||
@Produces
|
||||
@Dependent
|
||||
public PersonRepository create(final EventStore eventStore) {
|
||||
return new PersonRepository(eventStore);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.cmd.domain;
|
||||
|
||||
/**
|
||||
* Domain specific code like aggregate root classes and their repositories.
|
||||
*/
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.cmd;
|
||||
|
||||
/**
|
||||
* Code used for the command (write) side of the application.
|
||||
*/
|
||||
@@ -0,0 +1,8 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.app;
|
||||
|
||||
/**
|
||||
* Notifies the projectors to check for view updates.
|
||||
*/
|
||||
public class QryCheckForViewUpdatesEvent {
|
||||
|
||||
}
|
||||
@@ -0,0 +1,31 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.app;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.inject.Disposes;
|
||||
import javax.enterprise.inject.Produces;
|
||||
import javax.persistence.EntityManager;
|
||||
import javax.persistence.EntityManagerFactory;
|
||||
import javax.persistence.Persistence;
|
||||
|
||||
import org.apache.deltaspike.jpa.api.transaction.TransactionScoped;
|
||||
|
||||
@ApplicationScoped
|
||||
public class QryEntityManagerProducer {
|
||||
|
||||
private EntityManagerFactory emf;
|
||||
|
||||
@Produces
|
||||
@TransactionScoped
|
||||
public EntityManager create() {
|
||||
if (emf == null) {
|
||||
emf = Persistence.createEntityManagerFactory("QueryDb");
|
||||
}
|
||||
return emf.createEntityManager();
|
||||
}
|
||||
|
||||
public void close(@Disposes EntityManager em) {
|
||||
if (em.isOpen()) {
|
||||
em.close();
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,86 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.qry.app;
|
||||
|
||||
import java.util.concurrent.ExecutionException;
|
||||
import java.util.concurrent.ScheduledExecutorService;
|
||||
import java.util.concurrent.ScheduledFuture;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
import javax.enterprise.inject.se.SeContainer;
|
||||
import javax.enterprise.inject.se.SeContainerInitializer;
|
||||
import javax.inject.Inject;
|
||||
|
||||
import org.fuin.ext4logback.LogbackStandalone;
|
||||
import org.fuin.ext4logback.NewLogConfigFileParams;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* Minimal example command (write) application.
|
||||
*/
|
||||
public class QryExampleApp {
|
||||
|
||||
private static final Logger LOG = LoggerFactory.getLogger(QryExampleApp.class);
|
||||
|
||||
@Inject
|
||||
private ScheduledExecutorService scheduledExecutorService;
|
||||
|
||||
@Inject
|
||||
private QryTimer qryTimer;
|
||||
|
||||
/**
|
||||
* Executes the application.
|
||||
*/
|
||||
public void execute() {
|
||||
LOG.info("Started execution...");
|
||||
|
||||
final ScheduledFuture<?> future = scheduledExecutorService.scheduleAtFixedRate(qryTimer, 5, 1, TimeUnit.SECONDS);
|
||||
try {
|
||||
future.get();
|
||||
} catch (InterruptedException | ExecutionException ex) {
|
||||
throw new RuntimeException(ex);
|
||||
}
|
||||
|
||||
LOG.info("Ended execution...");
|
||||
}
|
||||
|
||||
/**
|
||||
* Main entry point to the command line application.
|
||||
*
|
||||
* @param args
|
||||
* Not used.
|
||||
*/
|
||||
public static void main(final String[] args) {
|
||||
|
||||
try {
|
||||
|
||||
new LogbackStandalone().init(args, new NewLogConfigFileParams("org.fuin.dddcqrs4jexample", "logback"));
|
||||
|
||||
LOG.info("Started query example");
|
||||
|
||||
try (final SeContainer container = SeContainerInitializer.newInstance().initialize()) {
|
||||
final QryExampleApp app = container.select(QryExampleApp.class).get();
|
||||
app.execute();
|
||||
}
|
||||
|
||||
LOG.info("Query example is running until you kill it...");
|
||||
|
||||
} catch (final RuntimeException ex) {
|
||||
ex.printStackTrace(System.err);
|
||||
System.exit(1);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,62 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.app;
|
||||
|
||||
import java.net.MalformedURLException;
|
||||
import java.net.URL;
|
||||
import java.util.concurrent.ThreadFactory;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.context.Dependent;
|
||||
import javax.enterprise.inject.Disposes;
|
||||
import javax.enterprise.inject.Produces;
|
||||
|
||||
import org.apache.http.auth.AuthScope;
|
||||
import org.apache.http.auth.UsernamePasswordCredentials;
|
||||
import org.apache.http.client.CredentialsProvider;
|
||||
import org.apache.http.impl.client.BasicCredentialsProvider;
|
||||
import org.fuin.dddcqrs4jexample.shared.app.SharedConfig;
|
||||
import org.fuin.esc.api.ProjectionAdminEventStore;
|
||||
import org.fuin.esc.eshttp.ESEnvelopeType;
|
||||
import org.fuin.esc.eshttp.ESHttpEventStore;
|
||||
import org.fuin.esc.spi.SimpleSerializerDeserializerRegistry;
|
||||
|
||||
/**
|
||||
* CDI producer that creates an {@link ProjectionAdminEventStore}.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class QryProjectionAdminEventStoreFactory {
|
||||
|
||||
/**
|
||||
* Creates an event store that is capable of administering projections.
|
||||
*
|
||||
* @return Dependent scope projection admin event store.
|
||||
*/
|
||||
@Produces
|
||||
@Dependent
|
||||
public ProjectionAdminEventStore createProjectionAdminEventStore(final SharedConfig config, final ThreadFactory threadFactory) {
|
||||
final String url = "http://" + config.getEventStoreHost() + ":" + config.getEventStoreHttpPort();
|
||||
try {
|
||||
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
|
||||
final UsernamePasswordCredentials credentials = new UsernamePasswordCredentials(config.getEventStoreUser(),
|
||||
config.getEventStorePassword());
|
||||
credentialsProvider.setCredentials(AuthScope.ANY, credentials);
|
||||
final SimpleSerializerDeserializerRegistry registry = new SimpleSerializerDeserializerRegistry();
|
||||
final ProjectionAdminEventStore es = new ESHttpEventStore(threadFactory, new URL(url), ESEnvelopeType.JSON, registry, registry,
|
||||
credentialsProvider);
|
||||
es.open();
|
||||
return es;
|
||||
} catch (final MalformedURLException ex) {
|
||||
throw new RuntimeException("Failed to create URL: " + url, ex);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Closes the projection admin event store when the context is disposed.
|
||||
*
|
||||
* @param es
|
||||
* Projection admin event store to close.
|
||||
*/
|
||||
public void closeProjectionAdminEventStore(@Disposes ProjectionAdminEventStore es) {
|
||||
es.close();
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,22 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.app;
|
||||
|
||||
import java.util.concurrent.ScheduledExecutorService;
|
||||
import java.util.concurrent.ScheduledThreadPoolExecutor;
|
||||
import java.util.concurrent.ThreadFactory;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.inject.Produces;
|
||||
|
||||
/**
|
||||
* CDI producer that creates an {@link ScheduledExecutorService}.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class QryScheduledExecutorService {
|
||||
|
||||
@Produces
|
||||
@ApplicationScoped
|
||||
public ScheduledExecutorService create(ThreadFactory threadFactory) {
|
||||
return new ScheduledThreadPoolExecutor(1, threadFactory, (runnable, executor) -> { System.out.println("Execution blocked"); });
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.app;
|
||||
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.ThreadFactory;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.inject.Produces;
|
||||
|
||||
/**
|
||||
* Creates an thread factory.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class QryThreadFactoryFactory {
|
||||
|
||||
@ApplicationScoped
|
||||
@Produces
|
||||
public ThreadFactory create() {
|
||||
return Executors.defaultThreadFactory();
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,20 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.app;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.event.Event;
|
||||
import javax.inject.Inject;
|
||||
|
||||
@ApplicationScoped
|
||||
public class QryTimer implements Runnable {
|
||||
|
||||
@Inject
|
||||
private Event<QryCheckForViewUpdatesEvent> checkForViewUpdates;
|
||||
|
||||
/**
|
||||
* Notifies all listeners to check for view updates.
|
||||
*/
|
||||
public void run() {
|
||||
checkForViewUpdates.fireAsync(new QryCheckForViewUpdatesEvent());
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.qry.app;
|
||||
|
||||
/**
|
||||
* Query application specific code.
|
||||
*/
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.qry.basics;
|
||||
|
||||
/**
|
||||
* General helper classes used by all other 'qry' packages.
|
||||
*/
|
||||
@@ -0,0 +1,96 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.domain;
|
||||
|
||||
import javax.persistence.Column;
|
||||
import javax.persistence.Entity;
|
||||
import javax.persistence.Id;
|
||||
import javax.persistence.Table;
|
||||
import javax.validation.constraints.NotNull;
|
||||
import javax.xml.bind.annotation.XmlAccessType;
|
||||
import javax.xml.bind.annotation.XmlAccessorType;
|
||||
import javax.xml.bind.annotation.XmlElement;
|
||||
import javax.xml.bind.annotation.XmlRootElement;
|
||||
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonId;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonName;
|
||||
import org.fuin.objects4j.common.Contract;
|
||||
|
||||
/**
|
||||
* Represents a person that will be stored in the database.
|
||||
*/
|
||||
@Entity
|
||||
@Table(name = "QRY_PERSON")
|
||||
@XmlAccessorType(XmlAccessType.FIELD)
|
||||
@XmlRootElement(name = "qry-person")
|
||||
public class QryPerson {
|
||||
|
||||
@Id
|
||||
@Column(name = "ID", nullable = false, length = 36, updatable = false)
|
||||
@NotNull
|
||||
@XmlElement(name = "id")
|
||||
private String id;
|
||||
|
||||
@Column(name = "NAME", nullable = false, length = PersonName.MAX_LENGTH, updatable = true)
|
||||
@NotNull
|
||||
@XmlElement(name = "name")
|
||||
private String name;
|
||||
|
||||
/**
|
||||
* JAX-B constructor.
|
||||
*/
|
||||
protected QryPerson() {
|
||||
super();
|
||||
}
|
||||
|
||||
/**
|
||||
* Constructor with all data.
|
||||
*
|
||||
* @param id
|
||||
* Unique aggregate identifier.
|
||||
* @param name
|
||||
* Name of the created person
|
||||
*/
|
||||
public QryPerson(@NotNull final PersonId id, @NotNull final PersonName name) {
|
||||
super();
|
||||
Contract.requireArgNotNull("id", id);
|
||||
Contract.requireArgNotNull("name", name);
|
||||
this.id = id.asString();
|
||||
this.name = name.asString();
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the unique person identifier.
|
||||
*
|
||||
* @return Aggregate ID.
|
||||
*/
|
||||
@NotNull
|
||||
public PersonId getId() {
|
||||
return PersonId.valueOf(id);
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the name of the person to create.
|
||||
*
|
||||
* @return the Person name
|
||||
*/
|
||||
@NotNull
|
||||
public PersonName getName() {
|
||||
return new PersonName(name);
|
||||
}
|
||||
|
||||
/**
|
||||
* Sets the name of the person.
|
||||
*
|
||||
* @param name
|
||||
* Name to set.
|
||||
*/
|
||||
public void setName(@NotNull final PersonName name) {
|
||||
Contract.requireArgNotNull("name", name);
|
||||
this.name = name.asString();
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
return "QryPerson [id=" + id + ", name=" + name + "]";
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,12 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.domain;
|
||||
|
||||
import org.apache.deltaspike.data.api.EntityRepository;
|
||||
import org.apache.deltaspike.data.api.Repository;
|
||||
|
||||
/**
|
||||
* Database service for persons.
|
||||
*/
|
||||
@Repository(forEntity = QryPerson.class)
|
||||
public interface QryPersonRepository extends EntityRepository<QryPerson, String> {
|
||||
|
||||
}
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.qry.domain;
|
||||
|
||||
/**
|
||||
* Domain specific code like view objects.
|
||||
*/
|
||||
@@ -0,0 +1,43 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.handler;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.inject.Inject;
|
||||
|
||||
import org.apache.deltaspike.jpa.api.transaction.Transactional;
|
||||
import org.fuin.cqrs4j.EventHandler;
|
||||
import org.fuin.ddd4j.ddd.EventType;
|
||||
import org.fuin.dddcqrs4jexample.qry.domain.QryPerson;
|
||||
import org.fuin.dddcqrs4jexample.qry.domain.QryPersonRepository;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonCreatedEvent;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonId;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* Handles the {@link PersonCreatedEvent}.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class PersonCreatedEventHandler implements EventHandler<PersonCreatedEvent> {
|
||||
|
||||
private static final Logger LOG = LoggerFactory.getLogger(PersonCreatedEventHandler.class);
|
||||
|
||||
@Inject
|
||||
private QryPersonRepository repo;
|
||||
|
||||
@Override
|
||||
public EventType getEventType() {
|
||||
return PersonCreatedEvent.TYPE;
|
||||
}
|
||||
|
||||
@Override
|
||||
@Transactional
|
||||
public void handle(final PersonCreatedEvent event) {
|
||||
LOG.info("Handle " + event);
|
||||
final PersonId personId = event.getEntityId();
|
||||
if (repo.findBy(personId.asString()) == null) {
|
||||
repo.save(new QryPerson(personId, event.getName()));
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,50 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.handler;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.inject.Inject;
|
||||
|
||||
import org.apache.deltaspike.jpa.api.transaction.Transactional;
|
||||
import org.fuin.cqrs4j.EventDispatcher;
|
||||
import org.fuin.cqrs4j.ProjectionService;
|
||||
import org.fuin.esc.api.ProjectionStreamId;
|
||||
import org.fuin.esc.api.StreamEventsSlice;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
@ApplicationScoped
|
||||
@Transactional
|
||||
public class QryEventChunkHandler {
|
||||
|
||||
private static final Logger LOG = LoggerFactory.getLogger(QryEventChunkHandler.class);
|
||||
|
||||
/** Unique name of the event store projection that is used. */
|
||||
public static final ProjectionStreamId PROJECTION_STREAM_ID = new ProjectionStreamId("qry-person-stream");
|
||||
|
||||
@Inject
|
||||
private EventDispatcher dispatcher;
|
||||
|
||||
@Inject
|
||||
private ProjectionService projectionService;
|
||||
|
||||
/**
|
||||
* Returns the next event position to read.
|
||||
*
|
||||
* @return Number of the next event to read.
|
||||
*/
|
||||
public Long readNextEventNumber() {
|
||||
return projectionService.readProjectionPosition(PROJECTION_STREAM_ID);
|
||||
}
|
||||
|
||||
/**
|
||||
* Handles the current slice as a single transaction.
|
||||
*
|
||||
* @param currentSlice
|
||||
* Slice with events to dispatch.
|
||||
*/
|
||||
public void handleChunk(final StreamEventsSlice currentSlice) {
|
||||
LOG.debug("Handle chunk: {}", currentSlice);
|
||||
dispatcher.dispatchCommonEvents(currentSlice.getEvents());
|
||||
projectionService.updateProjectionPosition(PROJECTION_STREAM_ID, currentSlice.getNextEventNumber());
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.handler;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.inject.Produces;
|
||||
|
||||
import org.fuin.cqrs4j.EventDispatcher;
|
||||
import org.fuin.cqrs4j.SimpleEventDispatcher;
|
||||
|
||||
/**
|
||||
* Create an {@link EventDispatcher}.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class QryEventDispatcherFactory {
|
||||
|
||||
@Produces
|
||||
@ApplicationScoped
|
||||
public EventDispatcher createDispatcher(final PersonCreatedEventHandler createdHandler) {
|
||||
return new SimpleEventDispatcher(createdHandler);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,88 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.handler;
|
||||
|
||||
import javax.persistence.Column;
|
||||
import javax.persistence.Entity;
|
||||
import javax.persistence.Id;
|
||||
import javax.persistence.Table;
|
||||
import javax.validation.constraints.NotNull;
|
||||
|
||||
import org.fuin.esc.api.SimpleStreamId;
|
||||
import org.fuin.esc.api.StreamId;
|
||||
import org.fuin.objects4j.common.Contract;
|
||||
|
||||
/**
|
||||
* Stores the next position to read from the projection in the event store.
|
||||
*/
|
||||
@Entity
|
||||
@Table(name = "QRY_PERSON_PROJECTION_POS")
|
||||
public class QryPersonProjectionPosition {
|
||||
|
||||
@Id
|
||||
@Column(name = "STREAM_ID", nullable = false, length = 250, updatable = false)
|
||||
@NotNull
|
||||
private String streamId;
|
||||
|
||||
@Column(name = "NEXT_POS", nullable = false, updatable = true)
|
||||
@NotNull
|
||||
private Long nextPos;
|
||||
|
||||
/**
|
||||
* JPA constructor.
|
||||
*/
|
||||
protected QryPersonProjectionPosition() {
|
||||
super();
|
||||
}
|
||||
|
||||
/**
|
||||
* Constructor with mandatory data.
|
||||
*
|
||||
* @param streamId
|
||||
* Unique stream identifier.
|
||||
* @param nextPos
|
||||
* Next position from the stream to read.
|
||||
*/
|
||||
public QryPersonProjectionPosition(@NotNull final StreamId streamId, @NotNull final Long nextPos) {
|
||||
super();
|
||||
Contract.requireArgNotNull("streamId", streamId);
|
||||
Contract.requireArgNotNull("nextPos", nextPos);
|
||||
this.streamId = streamId.asString();
|
||||
this.nextPos = nextPos;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the unique stream identifier.
|
||||
*
|
||||
* @return Stream ID.
|
||||
*/
|
||||
@NotNull
|
||||
public StreamId getStreamId() {
|
||||
return new SimpleStreamId(streamId);
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the next position read from the stream.
|
||||
*
|
||||
* @return Position to read next time.
|
||||
*/
|
||||
@NotNull
|
||||
public Long getNextPos() {
|
||||
return nextPos;
|
||||
}
|
||||
|
||||
/**
|
||||
* Sets the next position read from the stream.
|
||||
*
|
||||
* @param nextPos
|
||||
* New position to set.
|
||||
*/
|
||||
public void setNextPosition(@NotNull final Long nextPos) {
|
||||
Contract.requireArgNotNull("nextPos", nextPos);
|
||||
this.nextPos = nextPos;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
return "QryPersonHandlerPosition [streamId=" + streamId + ", nextPos=" + nextPos + "]";
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,50 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.handler;
|
||||
|
||||
import javax.validation.constraints.NotNull;
|
||||
|
||||
import org.apache.deltaspike.data.api.AbstractEntityRepository;
|
||||
import org.apache.deltaspike.data.api.Repository;
|
||||
import org.fuin.cqrs4j.ProjectionService;
|
||||
import org.fuin.esc.api.StreamId;
|
||||
import org.fuin.objects4j.common.Contract;
|
||||
|
||||
/**
|
||||
* Repository that contains the position of the stream.
|
||||
*/
|
||||
@Repository(forEntity = QryPersonProjectionPosition.class)
|
||||
public abstract class QryPersonProjectionPositionRepository extends AbstractEntityRepository<QryPersonProjectionPosition, String>
|
||||
implements ProjectionService {
|
||||
|
||||
@Override
|
||||
public void resetProjectionPosition(@NotNull final StreamId streamId) {
|
||||
Contract.requireArgNotNull("streamId", streamId);
|
||||
final QryPersonProjectionPosition pos = findBy(streamId.asString());
|
||||
if (pos != null) {
|
||||
pos.setNextPosition(0L);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public Long readProjectionPosition(@NotNull StreamId streamId) {
|
||||
Contract.requireArgNotNull("streamId", streamId);
|
||||
final QryPersonProjectionPosition pos = findBy(streamId.asString());
|
||||
if (pos == null) {
|
||||
return 0L;
|
||||
}
|
||||
return pos.getNextPos();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void updateProjectionPosition(@NotNull StreamId streamId, @NotNull Long nextEventNumber) {
|
||||
Contract.requireArgNotNull("streamId", streamId);
|
||||
Contract.requireArgNotNull("nextEventNumber", nextEventNumber);
|
||||
QryPersonProjectionPosition pos = findBy(streamId.asString());
|
||||
if (pos == null) {
|
||||
pos = new QryPersonProjectionPosition(streamId, nextEventNumber);
|
||||
} else {
|
||||
pos.setNextPosition(nextEventNumber);
|
||||
}
|
||||
save(pos);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,87 @@
|
||||
package org.fuin.dddcqrs4jexample.qry.handler;
|
||||
|
||||
import static org.fuin.cqrs4j.Cqrs4JUtils.tryLocked;
|
||||
import static org.fuin.dddcqrs4jexample.qry.handler.QryEventChunkHandler.PROJECTION_STREAM_ID;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.Semaphore;
|
||||
|
||||
import javax.enterprise.event.ObservesAsync;
|
||||
import javax.inject.Inject;
|
||||
|
||||
import org.fuin.cqrs4j.EventDispatcher;
|
||||
import org.fuin.ddd4j.ddd.EventType;
|
||||
import org.fuin.dddcqrs4jexample.qry.app.QryCheckForViewUpdatesEvent;
|
||||
import org.fuin.esc.api.EventStore;
|
||||
import org.fuin.esc.api.ProjectionAdminEventStore;
|
||||
import org.fuin.esc.api.TypeName;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* Reads incoming events from an attached event store and dispatches them to the appropriate event handlers.
|
||||
*/
|
||||
public class QryProjector {
|
||||
|
||||
private static final Logger LOG = LoggerFactory.getLogger(QryProjector.class);
|
||||
|
||||
/** Prevents more than one projector thread running at a time. */
|
||||
private static final Semaphore LOCK = new Semaphore(1);
|
||||
|
||||
// The following beans are NOT thread safe!
|
||||
// Above LOCK prevents multithreaded access
|
||||
|
||||
@Inject
|
||||
private ProjectionAdminEventStore eventstore;
|
||||
|
||||
@Inject
|
||||
private EventStore eventStore;
|
||||
|
||||
@Inject
|
||||
private QryEventChunkHandler chunkHandler;
|
||||
|
||||
@Inject
|
||||
private EventDispatcher dispatcher;
|
||||
|
||||
/**
|
||||
* Listens for timer events. If a second timer event occurs while the previous call is still being executed, the method will simply be
|
||||
* skipped.
|
||||
*
|
||||
* @param event
|
||||
* Timer event.
|
||||
*/
|
||||
public void onEvent(@ObservesAsync final QryCheckForViewUpdatesEvent event) {
|
||||
tryLocked(LOCK, () -> {
|
||||
try {
|
||||
readStreamEvents();
|
||||
} catch (final RuntimeException ex) {
|
||||
LOG.error("Error reading events from stream", ex);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
private void readStreamEvents() {
|
||||
|
||||
// TODO Make sure a projection with the correct events exists
|
||||
// We must update the projection if new events are defined or some are removed!
|
||||
if (!eventstore.projectionExists(PROJECTION_STREAM_ID)) {
|
||||
final Set<EventType> eventTypes = dispatcher.getAllTypes();
|
||||
final List<TypeName> typeNames = new ArrayList<>();
|
||||
for (final EventType eventType : eventTypes) {
|
||||
typeNames.add(new TypeName(eventType.asBaseType()));
|
||||
}
|
||||
LOG.info("Create projection '{}' with events: {}", PROJECTION_STREAM_ID, typeNames);
|
||||
eventstore.createProjection(PROJECTION_STREAM_ID, true, typeNames);
|
||||
}
|
||||
|
||||
// Read and dispatch events
|
||||
final Long nextEventNumber = chunkHandler.readNextEventNumber();
|
||||
eventStore.readAllEventsForward(PROJECTION_STREAM_ID, nextEventNumber, 100, (currentSlice) -> {
|
||||
chunkHandler.handleChunk(currentSlice);
|
||||
});
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.qry.handler;
|
||||
|
||||
/**
|
||||
* Code related to event handlers.
|
||||
*/
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.qry;
|
||||
|
||||
/**
|
||||
* Code used for the query (read) side of the application.
|
||||
*/
|
||||
@@ -0,0 +1,132 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared.app;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.inject.Inject;
|
||||
|
||||
import org.eclipse.microprofile.config.inject.ConfigProperty;
|
||||
|
||||
/**
|
||||
* Application configuration.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class SharedConfig {
|
||||
|
||||
private static final String EVENT_STORE_HOST = "127.0.0.1";
|
||||
|
||||
private static final int EVENT_STORE_HTTP_PORT = 2113;
|
||||
|
||||
private static final int EVENT_STORE_TCP_PORT = 1113;
|
||||
|
||||
private static final String EVENT_STORE_USER = "admin";
|
||||
|
||||
private static final String EVENT_STORE_PASSWORD = "changeit";
|
||||
|
||||
@Inject
|
||||
@ConfigProperty(name = "EVENT_STORE_HOST", defaultValue = EVENT_STORE_HOST)
|
||||
private String eventStoreHost;
|
||||
|
||||
@Inject
|
||||
@ConfigProperty(name = "EVENT_STORE_HTTP_PORT", defaultValue = "" + EVENT_STORE_HTTP_PORT)
|
||||
private int eventStoreHttpPort;
|
||||
|
||||
@Inject
|
||||
@ConfigProperty(name = "EVENT_STORE_TCP_PORT", defaultValue = "" + EVENT_STORE_TCP_PORT)
|
||||
private int eventStoreTcpPort;
|
||||
|
||||
@Inject
|
||||
@ConfigProperty(name = "EVENT_STORE_USER", defaultValue = EVENT_STORE_USER)
|
||||
private String eventStoreUser;
|
||||
|
||||
@Inject
|
||||
@ConfigProperty(name = "EVENT_STORE_PASSWORD", defaultValue = EVENT_STORE_PASSWORD)
|
||||
private String eventStorePassword;
|
||||
|
||||
/**
|
||||
* Constructor using default values internally.
|
||||
*/
|
||||
public SharedConfig() {
|
||||
super();
|
||||
this.eventStoreHost = EVENT_STORE_HOST;
|
||||
this.eventStoreHttpPort = EVENT_STORE_HTTP_PORT;
|
||||
this.eventStoreTcpPort = EVENT_STORE_TCP_PORT;
|
||||
this.eventStoreUser = EVENT_STORE_USER;
|
||||
this.eventStorePassword = EVENT_STORE_PASSWORD;
|
||||
}
|
||||
|
||||
/**
|
||||
* Constructor with all data.
|
||||
*
|
||||
* @param eventStoreHost Host.
|
||||
* @param eventStoreHttpPort HTTP port
|
||||
* @param eventStoreTcpPort TCP port.
|
||||
* @param eventStoreUser User.
|
||||
* @param eventStorePassword Password.
|
||||
*/
|
||||
public SharedConfig(final String eventStoreHost, final int eventStoreHttpPort, final int eventStoreTcpPort,
|
||||
final String eventStoreUser, final String eventStorePassword) {
|
||||
super();
|
||||
this.eventStoreHost = eventStoreHost;
|
||||
this.eventStoreHttpPort = eventStoreHttpPort;
|
||||
this.eventStoreTcpPort = eventStoreTcpPort;
|
||||
this.eventStoreUser = eventStoreUser;
|
||||
this.eventStorePassword = eventStorePassword;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the host name of the event store.
|
||||
*
|
||||
* @return Name.
|
||||
*/
|
||||
public String getEventStoreHost() {
|
||||
return eventStoreHost;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the HTTP port of the event store.
|
||||
*
|
||||
* @return Port.
|
||||
*/
|
||||
public int getEventStoreHttpPort() {
|
||||
return eventStoreHttpPort;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the TCP port of the event store.
|
||||
*
|
||||
* @return Port.
|
||||
*/
|
||||
public int getEventStoreTcpPort() {
|
||||
return eventStoreTcpPort;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the username of the event store.
|
||||
*
|
||||
* @return Username.
|
||||
*/
|
||||
public String getEventStoreUser() {
|
||||
return eventStoreUser;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the password of the event store.
|
||||
*
|
||||
* @return Password.
|
||||
*/
|
||||
public String getEventStorePassword() {
|
||||
return eventStorePassword;
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,58 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved.
|
||||
* http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under
|
||||
* the terms of the GNU Lesser General Public License as published by the Free
|
||||
* Software Foundation; either version 3 of the License, or (at your option) any
|
||||
* later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT
|
||||
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
||||
* FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
|
||||
* details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License
|
||||
* along with this library. If not, see http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared.app;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
import org.fuin.ddd4j.ddd.EntityId;
|
||||
import org.fuin.ddd4j.ddd.EntityIdFactory;
|
||||
import org.fuin.ddd4j.ddd.SingleEntityIdFactory;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonId;
|
||||
|
||||
/**
|
||||
* Factory that creates entity identifier instances based on the type.
|
||||
*/
|
||||
public final class SharedEntityIdFactory implements EntityIdFactory {
|
||||
|
||||
private Map<String, SingleEntityIdFactory> map;
|
||||
|
||||
/**
|
||||
* Default constructor.
|
||||
*/
|
||||
public SharedEntityIdFactory() {
|
||||
super();
|
||||
map = new HashMap<String, SingleEntityIdFactory>();
|
||||
map.put(PersonId.TYPE.asString(), PersonId::valueOf);
|
||||
}
|
||||
|
||||
@Override
|
||||
public EntityId createEntityId(final String type, final String id) {
|
||||
final SingleEntityIdFactory factory = map.get(type);
|
||||
if (factory == null) {
|
||||
throw new IllegalArgumentException("Unknown type: " + type);
|
||||
}
|
||||
return factory.createEntityId(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean containsType(final String type) {
|
||||
return map.containsKey(type);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,37 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared.app;
|
||||
|
||||
import java.util.concurrent.Executors;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.inject.Produces;
|
||||
|
||||
import com.github.msemys.esjc.EventStore;
|
||||
import com.github.msemys.esjc.EventStoreBuilder;
|
||||
|
||||
/**
|
||||
* CDI producer that creates a {@link EventStore}.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class SharedEsjcEventStoreFactory {
|
||||
|
||||
@Produces
|
||||
@ApplicationScoped
|
||||
public EventStore createESJC(final SharedConfig config) {
|
||||
return EventStoreBuilder.newBuilder().singleNodeAddress(config.getEventStoreHost(), config.getEventStoreTcpPort())
|
||||
.executor(Executors.newFixedThreadPool(10)).userCredentials(config.getEventStoreUser(), config.getEventStorePassword())
|
||||
.build();
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,52 @@
|
||||
package org.fuin.dddcqrs4jexample.shared.app;
|
||||
|
||||
import java.nio.charset.Charset;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.context.RequestScoped;
|
||||
import javax.enterprise.inject.Disposes;
|
||||
import javax.enterprise.inject.Produces;
|
||||
|
||||
import org.fuin.esc.api.EventStore;
|
||||
import org.fuin.esc.esjc.ESJCEventStore;
|
||||
import org.fuin.esc.spi.EnhancedMimeType;
|
||||
import org.fuin.esc.spi.SerDeserializerRegistry;
|
||||
|
||||
/**
|
||||
* CDI factory that creates an event store connection and repositories.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class SharedEventStoreFactory {
|
||||
|
||||
/**
|
||||
* Creates an event store.<br>
|
||||
* <br>
|
||||
* CAUTION: The returned event store instance is NOT thread safe.
|
||||
*
|
||||
* @param es Native event store API.
|
||||
* @param registry Serialization registry.
|
||||
*
|
||||
* @return Dependent scope event store.
|
||||
*/
|
||||
@Produces
|
||||
@RequestScoped
|
||||
public EventStore createEventStore(final com.github.msemys.esjc.EventStore es,
|
||||
final SerDeserializerRegistry registry) {
|
||||
|
||||
final EventStore eventstore = new ESJCEventStore(es, registry, registry,
|
||||
EnhancedMimeType.create("application", "json", Charset.forName("utf-8")));
|
||||
eventstore.open();
|
||||
return eventstore;
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* Closes the event store when the context is disposed.
|
||||
*
|
||||
* @param es Event store to close.
|
||||
*/
|
||||
public void closeEventStore(@Disposes final EventStore es) {
|
||||
es.close();
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,33 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared.app;
|
||||
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.inject.Produces;
|
||||
|
||||
/**
|
||||
* Creates an executor service.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class SharedExecutorServiceFactory {
|
||||
|
||||
@ApplicationScoped
|
||||
@Produces
|
||||
public ExecutorService createExecutorService() {
|
||||
return Executors.newFixedThreadPool(10);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,34 @@
|
||||
package org.fuin.dddcqrs4jexample.shared.app;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.inject.Produces;
|
||||
|
||||
import org.fuin.esc.spi.JsonbDeSerializer;
|
||||
import org.fuin.esc.spi.SerDeserializerRegistry;
|
||||
import org.fuin.esc.spi.SerializedDataTypeRegistry;
|
||||
|
||||
/**
|
||||
* CDI bean that creates a {@link SerDeserializerRegistry}.
|
||||
*/
|
||||
@ApplicationScoped
|
||||
public class SharedSerDeserializerRegistryFactory {
|
||||
|
||||
@Produces
|
||||
@ApplicationScoped
|
||||
public SerDeserializerRegistry createRegistry() {
|
||||
|
||||
// Knows about all types for usage with JSON-B
|
||||
final SerializedDataTypeRegistry typeRegistry = SharedUtils.createTypeRegistry();
|
||||
|
||||
// Does the actual marshalling/unmarshalling
|
||||
final JsonbDeSerializer jsonbDeSer = SharedUtils.createJsonbDeSerializer();
|
||||
|
||||
// Registry connects the type with the appropriate serializer and de-serializer
|
||||
final SerDeserializerRegistry serDeserRegistry = SharedUtils.createSerDeserializerRegistry(typeRegistry,
|
||||
jsonbDeSer);
|
||||
|
||||
return serDeserRegistry;
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,170 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved.
|
||||
* http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under
|
||||
* the terms of the GNU Lesser General Public License as published by the Free
|
||||
* Software Foundation; either version 3 of the License, or (at your option) any
|
||||
* later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT
|
||||
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
||||
* FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
|
||||
* details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License
|
||||
* along with this library. If not, see http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared.app;
|
||||
|
||||
import java.nio.charset.Charset;
|
||||
|
||||
import javax.json.bind.adapter.JsonbAdapter;
|
||||
|
||||
import org.eclipse.yasson.FieldAccessStrategy;
|
||||
import org.fuin.ddd4j.ddd.EntityIdPathConverter;
|
||||
import org.fuin.ddd4j.ddd.EventIdConverter;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonCreatedEvent;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonId;
|
||||
import org.fuin.dddcqrs4jexample.shared.domain.PersonName;
|
||||
import org.fuin.esc.spi.Base64Data;
|
||||
import org.fuin.esc.spi.EscEvent;
|
||||
import org.fuin.esc.spi.EscEvents;
|
||||
import org.fuin.esc.spi.EscMeta;
|
||||
import org.fuin.esc.spi.EscSpiUtils;
|
||||
import org.fuin.esc.spi.JsonbDeSerializer;
|
||||
import org.fuin.esc.spi.SerDeserializerRegistry;
|
||||
import org.fuin.esc.spi.SerializedDataType;
|
||||
import org.fuin.esc.spi.SerializedDataTypeRegistry;
|
||||
import org.fuin.esc.spi.SimpleSerializedDataTypeRegistry;
|
||||
import org.fuin.esc.spi.SimpleSerializerDeserializerRegistry;
|
||||
|
||||
|
||||
/**
|
||||
* Utility code shared between command (write) and query (read) module.
|
||||
*/
|
||||
public final class SharedUtils {
|
||||
|
||||
/** All types that will be written into and read from the event store. */
|
||||
private static TypeClass[] USER_DEFINED_TYPES = new TypeClass[] {
|
||||
new TypeClass(PersonCreatedEvent.SER_TYPE, PersonCreatedEvent.class) };
|
||||
|
||||
/** All JSON-B adapters from this module. */
|
||||
public static JsonbAdapter<?, ?>[] JSONB_ADAPTERS = new JsonbAdapter<?, ?>[] { new EventIdConverter(),
|
||||
new EntityIdPathConverter(new SharedEntityIdFactory()), new PersonId.Converter(),
|
||||
new PersonName.Converter() };
|
||||
|
||||
private SharedUtils() {
|
||||
throw new UnsupportedOperationException("It is not allowed to create an instance of a utiliy class");
|
||||
}
|
||||
|
||||
/**
|
||||
* Create a registry that allows finding types (classes) based on their unique
|
||||
* type name.
|
||||
*
|
||||
* @return New instance.
|
||||
*/
|
||||
public static SerializedDataTypeRegistry createTypeRegistry() {
|
||||
|
||||
// Contains all types for usage with JSON-B
|
||||
final SimpleSerializedDataTypeRegistry typeRegistry = new SimpleSerializedDataTypeRegistry();
|
||||
|
||||
// Base types always needed
|
||||
typeRegistry.add(EscEvent.SER_TYPE, EscEvent.class);
|
||||
typeRegistry.add(EscEvents.SER_TYPE, EscEvents.class);
|
||||
typeRegistry.add(EscMeta.SER_TYPE, EscMeta.class);
|
||||
typeRegistry.add(Base64Data.SER_TYPE, Base64Data.class);
|
||||
|
||||
// User defined types
|
||||
for (final TypeClass tc : USER_DEFINED_TYPES) {
|
||||
typeRegistry.add(tc.getType(), tc.getClasz());
|
||||
}
|
||||
return typeRegistry;
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* Creates a registry that connects the type with the appropriate serializer and
|
||||
* de-serializer.
|
||||
*
|
||||
* @param typeRegistry Type registry (Mapping from type name to class).
|
||||
* @param jsonbDeSer JSON-B serializer/deserializer to use.
|
||||
*
|
||||
* @return New instance.
|
||||
*/
|
||||
public static SerDeserializerRegistry createSerDeserializerRegistry(final SerializedDataTypeRegistry typeRegistry,
|
||||
final JsonbDeSerializer jsonbDeSer) {
|
||||
|
||||
final SimpleSerializerDeserializerRegistry registry = new SimpleSerializerDeserializerRegistry();
|
||||
|
||||
// Base types always needed
|
||||
registry.add(EscEvents.SER_TYPE, "application/json", jsonbDeSer);
|
||||
registry.add(EscEvent.SER_TYPE, "application/json", jsonbDeSer);
|
||||
registry.add(EscMeta.SER_TYPE, "application/json", jsonbDeSer);
|
||||
registry.add(Base64Data.SER_TYPE, "application/json", jsonbDeSer);
|
||||
|
||||
// User defined types
|
||||
for (final TypeClass tc : USER_DEFINED_TYPES) {
|
||||
registry.add(tc.getType(), "application/json", jsonbDeSer);
|
||||
}
|
||||
jsonbDeSer.init(typeRegistry, registry, registry);
|
||||
|
||||
return registry;
|
||||
}
|
||||
|
||||
/**
|
||||
* Creates an instance of the JSON-B serializer/deserializer.
|
||||
*
|
||||
* @return New instance that is fully initialized with al necessary settings.
|
||||
*/
|
||||
public static JsonbDeSerializer createJsonbDeSerializer() {
|
||||
|
||||
return JsonbDeSerializer.builder().withSerializers(EscSpiUtils.createEscJsonbSerializers())
|
||||
.withDeserializers(EscSpiUtils.createEscJsonbDeserializers())
|
||||
.withAdapters(JSONB_ADAPTERS).withPropertyVisibilityStrategy(new FieldAccessStrategy())
|
||||
.withEncoding(Charset.forName("utf-8")).build();
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* Helper class for type/class combination.
|
||||
*/
|
||||
private static final class TypeClass {
|
||||
|
||||
private final SerializedDataType type;
|
||||
|
||||
private final Class<?> clasz;
|
||||
|
||||
/**
|
||||
* Constructor with all data.
|
||||
*
|
||||
* @param type Type.
|
||||
* @param clasz Class.
|
||||
*/
|
||||
public TypeClass(final SerializedDataType type, final Class<?> clasz) {
|
||||
super();
|
||||
this.type = type;
|
||||
this.clasz = clasz;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the type.
|
||||
*
|
||||
* @return Type.
|
||||
*/
|
||||
public SerializedDataType getType() {
|
||||
return type;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the class.
|
||||
*
|
||||
* @return Class.
|
||||
*/
|
||||
public Class<?> getClasz() {
|
||||
return clasz;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared.app;
|
||||
|
||||
/**
|
||||
* Application specific code to be shared between all modules.
|
||||
*/
|
||||
@@ -0,0 +1,87 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved.
|
||||
* http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under
|
||||
* the terms of the GNU Lesser General Public License as published by the Free
|
||||
* Software Foundation; either version 3 of the License, or (at your option) any
|
||||
* later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT
|
||||
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
||||
* FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
|
||||
* details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License
|
||||
* along with this library. If not, see http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared.domain;
|
||||
|
||||
import javax.annotation.concurrent.Immutable;
|
||||
import javax.json.bind.annotation.JsonbProperty;
|
||||
import javax.validation.constraints.NotNull;
|
||||
|
||||
import org.fuin.ddd4j.ddd.AbstractDomainEvent;
|
||||
import org.fuin.ddd4j.ddd.EntityIdPath;
|
||||
import org.fuin.ddd4j.ddd.EventType;
|
||||
import org.fuin.esc.spi.SerializedDataType;
|
||||
import org.fuin.objects4j.common.Contract;
|
||||
|
||||
/**
|
||||
* A new person was created in the system.
|
||||
*/
|
||||
@Immutable
|
||||
public final class PersonCreatedEvent extends AbstractDomainEvent<PersonId> {
|
||||
|
||||
private static final long serialVersionUID = 1000L;
|
||||
|
||||
/** Never changing unique event type name. */
|
||||
public static final EventType TYPE = new EventType("PersonCreatedEvent");
|
||||
|
||||
/** Unique name used for marshalling/unmarshalling the event. */
|
||||
public static final SerializedDataType SER_TYPE = new SerializedDataType(PersonCreatedEvent.TYPE.asBaseType());
|
||||
|
||||
@NotNull
|
||||
@JsonbProperty("name")
|
||||
private PersonName name;
|
||||
|
||||
/**
|
||||
* Protected default constructor for deserialization.
|
||||
*/
|
||||
protected PersonCreatedEvent() {
|
||||
super();
|
||||
}
|
||||
|
||||
/**
|
||||
* A new person was created in the system.
|
||||
*
|
||||
* @param id Identifies uniquely a person.
|
||||
* @param name Name of a person.
|
||||
*/
|
||||
public PersonCreatedEvent(@NotNull final PersonId id, @NotNull final PersonName name) {
|
||||
super(new EntityIdPath(id));
|
||||
Contract.requireArgNotNull("name", name);
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
@Override
|
||||
public final EventType getEventType() {
|
||||
return PersonCreatedEvent.TYPE;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns: Name of a person.
|
||||
*
|
||||
* @return Current value.
|
||||
*/
|
||||
@NotNull
|
||||
public final PersonName getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
@Override
|
||||
public final String toString() {
|
||||
return "Person '" + name + "' was created";
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,132 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved.
|
||||
* http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under
|
||||
* the terms of the GNU Lesser General Public License as published by the Free
|
||||
* Software Foundation; either version 3 of the License, or (at your option) any
|
||||
* later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT
|
||||
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
||||
* FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
|
||||
* details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License
|
||||
* along with this library. If not, see http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared.domain;
|
||||
|
||||
import java.util.UUID;
|
||||
|
||||
import javax.annotation.concurrent.Immutable;
|
||||
import javax.json.bind.adapter.JsonbAdapter;
|
||||
import javax.validation.constraints.NotNull;
|
||||
|
||||
import org.fuin.ddd4j.ddd.AggregateRootUuid;
|
||||
import org.fuin.ddd4j.ddd.EntityType;
|
||||
import org.fuin.ddd4j.ddd.StringBasedEntityType;
|
||||
import org.fuin.objects4j.ui.Label;
|
||||
import org.fuin.objects4j.ui.ShortLabel;
|
||||
import org.fuin.objects4j.ui.Tooltip;
|
||||
import org.fuin.objects4j.vo.ValueObjectConverter;
|
||||
|
||||
/**
|
||||
* Identifies uniquely a person.
|
||||
*/
|
||||
@ShortLabel(bundle = "ddd-cqrs-4-java-example", key = "PersonId.slabel", value = "PID")
|
||||
@Label(bundle = "ddd-cqrs-4-java-example", key = "PersonId.label", value = "Person's ID")
|
||||
@Tooltip(bundle = "ddd-cqrs-4-java-example", key = "PersonId.tooltip", value = "Unique identifier of a person")
|
||||
@Immutable
|
||||
public final class PersonId extends AggregateRootUuid {
|
||||
|
||||
private static final long serialVersionUID = 1000L;
|
||||
|
||||
/** Unique name of the aggregate this identifier refers to. */
|
||||
public static final EntityType TYPE = new StringBasedEntityType("PERSON");
|
||||
|
||||
/**
|
||||
* Default constructor.
|
||||
*/
|
||||
protected PersonId() {
|
||||
super(PersonId.TYPE);
|
||||
}
|
||||
|
||||
/**
|
||||
* Constructor with all data.
|
||||
*
|
||||
* @param value Persistent value.
|
||||
*/
|
||||
public PersonId(@NotNull final UUID value) {
|
||||
super(PersonId.TYPE, value);
|
||||
}
|
||||
|
||||
/**
|
||||
* Parses a given string and returns a new instance of PersonId.
|
||||
*
|
||||
* @param value String with valid UUID to convert. A <code>null</code> value
|
||||
* returns <code>null</code>.
|
||||
*
|
||||
* @return Converted value.
|
||||
*/
|
||||
public static PersonId valueOf(final String value) {
|
||||
if (value == null) {
|
||||
return null;
|
||||
}
|
||||
AggregateRootUuid.requireArgValid("value", value);
|
||||
return new PersonId(UUID.fromString(value));
|
||||
}
|
||||
|
||||
/**
|
||||
* Converts the value object from/to UUID.
|
||||
*/
|
||||
public static final class Converter implements ValueObjectConverter<UUID, PersonId>, JsonbAdapter<PersonId, UUID> {
|
||||
|
||||
// Attribute Converter
|
||||
|
||||
@Override
|
||||
public final Class<UUID> getBaseTypeClass() {
|
||||
return UUID.class;
|
||||
}
|
||||
|
||||
@Override
|
||||
public final Class<PersonId> getValueObjectClass() {
|
||||
return PersonId.class;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean isValid(final UUID value) {
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public final PersonId toVO(final UUID value) {
|
||||
if (value == null) {
|
||||
return null;
|
||||
}
|
||||
return new PersonId(value);
|
||||
}
|
||||
|
||||
@Override
|
||||
public final UUID fromVO(final PersonId value) {
|
||||
if (value == null) {
|
||||
return null;
|
||||
}
|
||||
return value.asBaseType();
|
||||
}
|
||||
|
||||
// JSONB Adapter
|
||||
|
||||
@Override
|
||||
public final UUID adaptToJson(final PersonId obj) throws Exception {
|
||||
return fromVO(obj);
|
||||
}
|
||||
|
||||
@Override
|
||||
public final PersonId adaptFromJson(final UUID value) throws Exception {
|
||||
return toVO(value);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,216 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved.
|
||||
* http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under
|
||||
* the terms of the GNU Lesser General Public License as published by the Free
|
||||
* Software Foundation; either version 3 of the License, or (at your option) any
|
||||
* later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT
|
||||
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
||||
* FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
|
||||
* details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License
|
||||
* along with this library. If not, see http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared.domain;
|
||||
|
||||
import java.lang.annotation.Documented;
|
||||
import java.lang.annotation.ElementType;
|
||||
import java.lang.annotation.Retention;
|
||||
import java.lang.annotation.RetentionPolicy;
|
||||
import java.lang.annotation.Target;
|
||||
|
||||
import javax.annotation.concurrent.Immutable;
|
||||
import javax.json.bind.adapter.JsonbAdapter;
|
||||
import javax.validation.Constraint;
|
||||
import javax.validation.ConstraintValidator;
|
||||
import javax.validation.ConstraintValidatorContext;
|
||||
import javax.validation.Payload;
|
||||
import javax.validation.constraints.NotNull;
|
||||
|
||||
import org.fuin.objects4j.common.ConstraintViolationException;
|
||||
import org.fuin.objects4j.ui.Label;
|
||||
import org.fuin.objects4j.ui.ShortLabel;
|
||||
import org.fuin.objects4j.ui.Tooltip;
|
||||
import org.fuin.objects4j.vo.AbstractStringValueObject;
|
||||
import org.fuin.objects4j.vo.ValueObjectConverter;
|
||||
|
||||
/**
|
||||
* Name of a person.
|
||||
*/
|
||||
@ShortLabel(bundle = "ddd-cqrs-4-java-example", key = "PersonName.slabel", value = "PNAME")
|
||||
@Label(bundle = "ddd-cqrs-4-java-example", key = "PersonName.label", value = "Person's name")
|
||||
@Tooltip(bundle = "ddd-cqrs-4-java-example", key = "PersonName.tooltip", value = "Name of a person")
|
||||
@Immutable
|
||||
public final class PersonName extends AbstractStringValueObject {
|
||||
|
||||
private static final long serialVersionUID = 1000L;
|
||||
|
||||
/** Max length of a person's name. */
|
||||
public static final int MAX_LENGTH = 100;
|
||||
|
||||
@NotNull
|
||||
@PersonNameStr
|
||||
private String value;
|
||||
|
||||
/**
|
||||
* Protected default constructor for deserialization.
|
||||
*/
|
||||
protected PersonName() {
|
||||
super();
|
||||
}
|
||||
|
||||
/**
|
||||
* Constructor with mandatory data.
|
||||
*
|
||||
* @param value Value.
|
||||
*/
|
||||
public PersonName(final String value) {
|
||||
super();
|
||||
PersonName.requireArgValid("value", value);
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
@Override
|
||||
public final String asBaseType() {
|
||||
return value;
|
||||
}
|
||||
|
||||
@Override
|
||||
public final String toString() {
|
||||
return value;
|
||||
}
|
||||
|
||||
/**
|
||||
* Verifies that a given string can be converted into the type.
|
||||
*
|
||||
* @param value Value to validate.
|
||||
*
|
||||
* @return Returns <code>true</code> if it's a valid type else
|
||||
* <code>false</code>.
|
||||
*/
|
||||
public static boolean isValid(final String value) {
|
||||
if (value == null) {
|
||||
return true;
|
||||
}
|
||||
if (value.length() == 0) {
|
||||
return false;
|
||||
}
|
||||
final String trimmed = value.trim();
|
||||
if (trimmed.length() > PersonName.MAX_LENGTH) {
|
||||
return false;
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Verifies if the argument is valid and throws an exception if this is not the
|
||||
* case.
|
||||
*
|
||||
* @param name Name of the value for a possible error message.
|
||||
* @param value Value to check.
|
||||
*
|
||||
* @throws ConstraintViolationException The value was not valid.
|
||||
*/
|
||||
public static void requireArgValid(@NotNull final String name, @NotNull final String value)
|
||||
throws ConstraintViolationException {
|
||||
|
||||
if (!PersonName.isValid(value)) {
|
||||
throw new ConstraintViolationException("The argument '" + name + "' is not valid: '" + value + "'");
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* Ensures that the string can be converted into the type.
|
||||
*/
|
||||
@Target({ ElementType.METHOD, ElementType.PARAMETER, ElementType.FIELD, ElementType.ANNOTATION_TYPE })
|
||||
@Retention(RetentionPolicy.RUNTIME)
|
||||
@Constraint(validatedBy = { Validator.class })
|
||||
@Documented
|
||||
public static @interface PersonNameStr {
|
||||
|
||||
String message()
|
||||
|
||||
default "{org.fuin.dddcqrs4jexample.PersonName.message}";
|
||||
|
||||
Class<?>[] groups() default {};
|
||||
|
||||
Class<? extends Payload>[] payload() default {};
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* Validates if a string is compliant with the type.
|
||||
*/
|
||||
public static final class Validator implements ConstraintValidator<PersonNameStr, String> {
|
||||
|
||||
@Override
|
||||
public final void initialize(final PersonNameStr annotation) {
|
||||
// Not used
|
||||
}
|
||||
|
||||
@Override
|
||||
public final boolean isValid(final String value, final ConstraintValidatorContext context) {
|
||||
return PersonName.isValid(value);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* Converts the value object from/to string.
|
||||
*/
|
||||
public static final class Converter
|
||||
implements ValueObjectConverter<String, PersonName>, JsonbAdapter<PersonName, String> {
|
||||
|
||||
// Attribute Converter
|
||||
|
||||
@Override
|
||||
public final Class<String> getBaseTypeClass() {
|
||||
return String.class;
|
||||
}
|
||||
|
||||
@Override
|
||||
public final Class<PersonName> getValueObjectClass() {
|
||||
return PersonName.class;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean isValid(final String value) {
|
||||
return PersonName.isValid(value);
|
||||
}
|
||||
|
||||
@Override
|
||||
public final PersonName toVO(final String value) {
|
||||
if (value == null) {
|
||||
return null;
|
||||
}
|
||||
return new PersonName(value);
|
||||
}
|
||||
|
||||
@Override
|
||||
public final String fromVO(final PersonName value) {
|
||||
if (value == null) {
|
||||
return null;
|
||||
}
|
||||
return value.asBaseType();
|
||||
}
|
||||
|
||||
// JSONB Adapter
|
||||
|
||||
@Override
|
||||
public final String adaptToJson(final PersonName obj) throws Exception {
|
||||
return fromVO(obj);
|
||||
}
|
||||
|
||||
@Override
|
||||
public final PersonName adaptFromJson(final String str) throws Exception {
|
||||
return toVO(str);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared.domain;
|
||||
|
||||
/**
|
||||
* Domain specific code to be shared between all modules.
|
||||
*/
|
||||
@@ -0,0 +1,17 @@
|
||||
/**
|
||||
* Copyright (C) 2015 Michael Schnell. All rights reserved. http://www.fuin.org/
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as
|
||||
* published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License along with this library. If not, see
|
||||
* http://www.gnu.org/licenses/.
|
||||
*/
|
||||
package org.fuin.dddcqrs4jexample.shared;
|
||||
|
||||
/**
|
||||
* Code shared between command (write) and query (read) modules.
|
||||
*/
|
||||
10
src/main/resources/META-INF/beans.xml
Normal file
10
src/main/resources/META-INF/beans.xml
Normal file
@@ -0,0 +1,10 @@
|
||||
<beans xmlns="http://java.sun.com/xml/ns/javaee"
|
||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/beans_1_0.xsd" >
|
||||
|
||||
|
||||
<alternatives>
|
||||
<class>org.apache.deltaspike.jpa.impl.transaction.BeanManagedUserTransactionStrategy</class>
|
||||
</alternatives>
|
||||
|
||||
</beans>
|
||||
27
src/main/resources/META-INF/persistence.xml
Normal file
27
src/main/resources/META-INF/persistence.xml
Normal file
@@ -0,0 +1,27 @@
|
||||
<persistence xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd"
|
||||
version="2.0" xmlns="http://java.sun.com/xml/ns/persistence">
|
||||
|
||||
<persistence-unit name="QueryDb" transaction-type="RESOURCE_LOCAL">
|
||||
|
||||
<class>org.fuin.dddcqrs4jexample.qry.handler.QryPersonProjectionPosition</class>
|
||||
<class>org.fuin.dddcqrs4jexample.qry.domain.QryPerson</class>
|
||||
<exclude-unlisted-classes>true</exclude-unlisted-classes>
|
||||
|
||||
<properties>
|
||||
<property name="javax.persistence.jdbc.driver" value="org.hsqldb.jdbcDriver" />
|
||||
<property name="javax.persistence.jdbc.url" value="jdbc:hsqldb:mem:querydb" />
|
||||
<property name="javax.persistence.jdbc.user" value="sa" />
|
||||
<property name="javax.persistence.jdbc.password" value="" />
|
||||
<property name="javax.persistence.schema-generation.database.action" value="drop-and-create" />
|
||||
|
||||
<property name="show_sql" value="true"/>
|
||||
|
||||
<property name="hibernate.dialect" value="org.hibernate.dialect.HSQLDialect"/>
|
||||
<property name="hibernate.temp.use_jdbc_metadata_defaults" value="false"/>
|
||||
|
||||
</properties>
|
||||
|
||||
</persistence-unit>
|
||||
|
||||
</persistence>
|
||||
Reference in New Issue
Block a user