Spring Boot Akka Event Sourcing Starter – Part 3 – The Working Example

2018-05-08T15:13:34+00:00

Hello!
Good tutorial!
Could you share full project source code?

2018-05-09T08:56:26+00:00

Let me know if you any further questions !

Romeh

	<dependency>
	<groupId>spring-akka-event-sourcing</groupId>
	<artifactId>springboot-akka-event-sourcing-starter</artifactId>
	<version>1.0</version>
	</dependency>

	spring:
	jackson:
	default-property-inclusion: non_null

	akka:
	config: eventSourcing.conf
	system-name: orderManagerSystem

	/**
	* get order state service API
	*
	* @param getOrderStatusCmd get Order state command
	* @return order state
	*/
	public CompletableFuture<OrderState> getOrderStatus(OrderCmd.GetOrderStatusCmd getOrderStatusCmd) {
	return PatternsCS.ask(getOrderEntity(), getOrderStatusCmd, timeout).toCompletableFuture()
	.thenApply(handleGetState);
	}

	/**
	* @return Persistent entity actor reference based into AKKA cluster sharding
	*/
	private final ActorRef getOrderEntity() {
	return persistentEntityBroker.findPersistentEntity(OrderManager.class);

	}

	/**
	* The main order domain REST API
	*
	* @author romeh
	*/

	@RestController
	@RequestMapping("/orders")
	@Api(value = "Order Manager REST API demo")
	public class OrderRestController {

	@Autowired
	private OrdersBroker ordersBroker;

	/**
	* @param orderRequest json order request
	* @return ASYNC generic JSON response
	*/
	@RequestMapping(method = RequestMethod.POST)
	public CompletableFuture<Response> createOrder(@RequestBody @Valid OrderRequest orderRequest) {
	return ordersBroker.createOrder(new OrderCmd.CreateCmd(UUID.randomUUID().toString(), orderRequest.getOrderDetails()));

	}
	}

	<plugin>
	<groupId>org.xolstice.maven.plugins</groupId>
	<artifactId>protobuf-maven-plugin</artifactId>
	<version>0.5.1</version>
	<configuration>
	<protocExecutable>/usr/local/opt/protobuf/bin/protoc</protocExecutable>
	</configuration>
	<executions>
	<execution>
	<goals>
	<goal>compile</goal>
	<goal>test-compile</goal>
	</goals>
	<configuration>
	<protocExecutable>/usr/local/opt/protobuf/bin/protoc</protocExecutable>
	</configuration>
	</execution>
	</executions>
	</plugin>

	<plugin>
	<groupId>org.codehaus.mojo</groupId>
	<artifactId>build-helper-maven-plugin</artifactId>
	<executions>
	<execution>
	<id>add-protobuf-generate-sources</id>
	<phase>generate-sources</phase>
	<goals>
	<goal>add-source</goal>
	</goals>
	<configuration>
	<sources>
	<source>target/generated-sources/protobuf/java</source>
	</sources>
	</configuration>
	</execution>

	<execution>
	<id>add-protobuf-generate-test-sources</id>
	<phase>generate-sources</phase>
	<goals>
	<goal>add-test-source</goal>
	</goals>
	<configuration>
	<sources>
	<source>target/generated-test-sources/protobuf/java</source>
	</sources>
	</configuration>
	</execution>
	</executions>
	</plugin>

3 comments