CQRS e Event Sourcing com Axon Framework e Spring Boot - EventController.java

EventController.java

package br.com.coderef.controller;

import lombok.AllArgsConstructor;
import org.axonframework.eventhandling.EventMessage;
import org.axonframework.eventsourcing.eventstore.EventStore;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.stream.Collectors;

@RestController
@AllArgsConstructor
@RequestMapping("/events")
public class EventController {

    private EventStore eventStore;

    @GetMapping
    @RequestMapping("/{aggregateId}")
    @Transactional(readOnly = true)
    public List<EventMessage> listEvents(@PathVariable String aggregateId) {
        return eventStore.readEvents(aggregateId)
                .asStream()
                .collect(Collectors.toList());
    }
}