abruzzi/axon-cqrs-demo

Axon CQRS Demo

👋 Hi I'm Juntao, I help people write better code.

I love the feeling of convert messy code into something more readable and maintainable, and I also enjoy the feeling of teach other to do so.

• Books I wrote about coding
• My Youtube Channel: I Code It
• Blogs about refactorings and clean code
• And my homepage.

@JuntaoQiu

axon-cqrs-demo's Issues

AppConfiguration

@Configuration
public class AppConfiguration {
    @Bean
    public AnnotationEventListenerBeanPostProcessor annotationEventListenerBeanPostProcessor() {
        AnnotationEventListenerBeanPostProcessor processor = new AnnotationEventListenerBeanPostProcessor();
        processor.setEventBus(eventBus());
        return processor;
    }

    @Bean
    public AnnotationCommandHandlerBeanPostProcessor annotationCommandHandlerBeanPostProcessor() {
        AnnotationCommandHandlerBeanPostProcessor processor = new AnnotationCommandHandlerBeanPostProcessor();
        processor.setCommandBus(commandBus());
        return processor;
    }

    @Bean
    public CommandBus commandBus() {
        SimpleCommandBus commandBus = new SimpleCommandBus();
        commandBus.setHandlerInterceptors(Arrays.asList(new BeanValidationInterceptor()));
        return commandBus;
    }

    @Bean
    public DefaultCommandGateway commandGateway() {
        return new DefaultCommandGateway(commandBus());
    }

    @Bean
    public EventBus eventBus() {
        return new SimpleEventBus();
    }

    @Bean
    public Repository<License> eventSourcingRepository() {
        FileSystemEventStore eventStore = new FileSystemEventStore(new SimpleEventFileResolver(new File("data/evenstore")));

        EventSourcingRepository<License> eventSourcingRepository = new EventSourcingRepository<>(License.class, eventStore);
        eventSourcingRepository.setEventBus(eventBus());

        return eventSourcingRepository;
    }

    @Bean
    public AggregateAnnotationCommandHandler<License> licenseCommandHandler() {
        return AggregateAnnotationCommandHandler.subscribe(License.class, eventSourcingRepository(), commandBus());
    }
}

LicenseTest

public class LicenseTest {
    private FixtureConfiguration fixture;

    @Before
    public void setUp() throws Exception {
        fixture = Fixtures.newGivenWhenThenFixture(License.class);
    }

    @Test
    public void import_license_command_and_event() throws Exception {
        fixture.given()
                .when(new ImportLicenseCommand("004c97", "desc"))
                .expectEvents(new LicenseImportedEvent("004c97", "desc"));
    }

    @Test
    public void import_license_and_activate_it() {
        fixture.given(new LicenseImportedEvent("004c97", "desc"))
                .when(new ActivateLicenseCommand("004c97"))
                .expectEvents(new LicenseActivatedEvent("004c97"));
    }

    @Test
    public void deactivate_license_after_activate() {
        fixture.given(Arrays.asList(new LicenseImportedEvent("004c97", "desc"), new LicenseActivatedEvent("004c97")))
                .when(new DeactivateLicenseCommand("004c97"))
                .expectEvents(new LicenseDeactivatedEvent("004c97"));
    }
}