Aggregator service

Aggregator service will to listen to a Message Queue, parse the JSON messages to Products and and saves them to the database. Also tracks if the Product is newly added or updated.

To be used together with the Importer service.

Getting Started

These instructions will get you a copy of the project up and running on your local machine for development and testing purposes.

Prerequisites

JDK 11 and Maven or Docker is required to run this project.

Build and Run

Maven

Build and run the project with Maven:

mvn package
mvn spring-boot:run

Docker

Use the following docker-compose to run the full project:

version: '3'
services:
  activemq:
    container_name: activemq
    image: vromero/activemq-artemis
    ports:
      - "8161:8161"
      - "61616:61616"
  importer:
    image: sergiopoliveira/importer
    ports:
      - "5050:5050"
    depends_on:
      - activemq
  aggregator:
     image: sergiopoliveira/aggregator
     ports:
      - "5051:5051"
     depends_on:
      - activemq
  zipkin:
     image: openzipkin/zipkin
     ports:
      - "9411:9411"

REST Endpoints

http://localhost:5051/api/v1/products -> List all products in the database
http://localhost:5051/api/v1/statistics/daily -> Get daily statistics for Products inserted or updated

Running the tests

Tests created using JUnit and Mockito. Run them as:

mvn test

Built With

• Java 11
• Spring Boot
• Spring Data JPA
• ActiveMQ
• MapStruct
• Maven
• JUnit, Mockito
• H2 in-memory database

Authors

• Sérgio Oliveira - sergiopoliveira

License

This project is licensed under the MIT License - see the LICENSE.md file for details