fix: rabbitmq event bus

Makefile

@@ -1,7 +1,7 @@
 all: build
 
 start:
-	@docker-compose -f docker-compose.ci.yml up -d
+	@docker compose -f docker-compose.ci.yml up -d
 
 build:
 	@./gradlew build --warning-mode all

apps/main/resources/application.properties

@@ -0,0 +1 @@
+spring.main.allow-bean-definition-overriding=true

apps/main/resources/backoffice_frontend/templates/pages/courses/partials/list_courses.ftl

@@ -142,12 +142,12 @@
 
         const urlParts = inputs.map(input => input.name + "=" + input.value);
 
-        const url = "http://localhost:8091/courses?" + urlParts.join("&");
+        const url = "http://localhost:8040/courses?" + urlParts.join("&");
 
         addCoursesList(url);
     }
 </script>
 
 <script>
-    addCoursesList("http://localhost:8091/courses");
+    addCoursesList("http://localhost:8040/courses");
 </script>

apps/main/tv/codely/apps/backoffice/backend/BackofficeBackendApplication.java

@@ -7,6 +7,7 @@
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.FilterType;
 
+import tv.codely.apps.backoffice.backend.command.ConsumeRabbitMqDomainEventsCommand;
 import tv.codely.shared.domain.Service;
 
 @SpringBootApplication(exclude = HibernateJpaAutoConfiguration.class)
@@ -17,8 +18,10 @@
 public class BackofficeBackendApplication {
 
 	public static HashMap<String, Class<?>> commands() {
-		return new HashMap<String, Class<?>>() {
-			{}
+		return new HashMap<>() {
+			{
+				put("domain-events:rabbitmq:consume", ConsumeRabbitMqDomainEventsCommand.class);
+			}
 		};
 	}
 }

apps/main/tv/codely/apps/backoffice/backend/command/ConsumeRabbitMqDomainEventsCommand.java

@@ -0,0 +1,18 @@
+package tv.codely.apps.backoffice.backend.command;
+
+import tv.codely.shared.infrastructure.bus.event.rabbitmq.RabbitMqDomainEventsConsumer;
+import tv.codely.shared.infrastructure.cli.ConsoleCommand;
+
+public final class ConsumeRabbitMqDomainEventsCommand extends ConsoleCommand {
+
+	private final RabbitMqDomainEventsConsumer consumer;
+
+	public ConsumeRabbitMqDomainEventsCommand(RabbitMqDomainEventsConsumer consumer) {
+		this.consumer = consumer;
+	}
+
+	@Override
+	public void execute(String[] args) {
+		consumer.consume("backoffice");
+	}
+}

apps/main/tv/codely/apps/backoffice/frontend/config/BackofficeFrontendWebConfig.java

@@ -1,7 +1,9 @@
 package tv.codely.apps.backoffice.frontend.config;
 
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
 import org.springframework.web.servlet.ViewResolver;
 import org.springframework.web.servlet.config.annotation.EnableWebMvc;
 import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
@@ -10,6 +12,10 @@
 import org.springframework.web.servlet.view.freemarker.FreeMarkerConfigurer;
 import org.springframework.web.servlet.view.freemarker.FreeMarkerViewResolver;
 
+import tv.codely.shared.infrastructure.bus.event.mysql.MySqlEventBus;
+import tv.codely.shared.infrastructure.bus.event.rabbitmq.RabbitMqEventBus;
+import tv.codely.shared.infrastructure.bus.event.rabbitmq.RabbitMqPublisher;
+
 @Configuration
 @EnableWebMvc
 public class BackofficeFrontendWebConfig implements WebMvcConfigurer {
@@ -43,4 +49,13 @@ public FreeMarkerConfigurer freeMarkerConfigurer() {
 
 		return configurer;
 	}
+
+	@Primary
+	@Bean
+	public RabbitMqEventBus rabbitMqEventBus(
+		RabbitMqPublisher publisher,
+		@Qualifier("backofficeMysqlEventBus") MySqlEventBus failoverPublisher
+	) {
+		return new RabbitMqEventBus(publisher, failoverPublisher);
+	}
 }

apps/main/tv/codely/apps/mooc/backend/command/ConsumeRabbitMqDomainEventsCommand.java

@@ -13,6 +13,6 @@ public ConsumeRabbitMqDomainEventsCommand(RabbitMqDomainEventsConsumer consumer)
 
 	@Override
 	public void execute(String[] args) {
-		consumer.consume();
+		consumer.consume("mooc");
 	}
 }

apps/main/tv/codely/apps/mooc/backend/config/MoocBackendServerConfiguration.java

@@ -1,5 +1,7 @@
 package tv.codely.apps.mooc.backend.config;
 
+import java.util.Optional;
+
 import org.springframework.boot.web.servlet.FilterRegistrationBean;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -10,17 +12,17 @@
 @Configuration
 public class MoocBackendServerConfiguration {
 
-	private final RequestMappingHandlerMapping mapping;
+	private final Optional<RequestMappingHandlerMapping> mapping;
 
-	public MoocBackendServerConfiguration(RequestMappingHandlerMapping mapping) {
+	public MoocBackendServerConfiguration(Optional<RequestMappingHandlerMapping> mapping) {
 		this.mapping = mapping;
 	}
 
 	@Bean
 	public FilterRegistrationBean<ApiExceptionMiddleware> apiExceptionMiddleware() {
 		FilterRegistrationBean<ApiExceptionMiddleware> registrationBean = new FilterRegistrationBean<>();
 
-		registrationBean.setFilter(new ApiExceptionMiddleware(mapping));
+		mapping.ifPresent(map -> registrationBean.setFilter(new ApiExceptionMiddleware(map)));
 
 		return registrationBean;
 	}

docker-compose.yml

@@ -51,12 +51,29 @@ services:
     volumes:
       - .:/app:delegated
       - backoffice_backend_gradle_cache:/app/.gradle
+      - backoffice_backend_build:/app/build
     depends_on:
       - shared_mysql
       - shared_rabbitmq
       - backoffice_elasticsearch
     command: ["./gradlew", "bootRun", "--args", "backoffice_backend server"]
 
+  backoffice_backend_consumers_java:
+    container_name: codely-java_ddd_example-backoffice_backend_consumers
+    build:
+      context: .
+      dockerfile: Dockerfile
+    restart: unless-stopped
+    volumes:
+      - .:/app:delegated
+      - backoffice_consumers_gradle_cache:/app/.gradle
+      - backoffice_consumers_build:/app/build
+    depends_on:
+      - shared_mysql
+      - shared_rabbitmq
+      - backoffice_elasticsearch
+    command: ["./gradlew", "bootRun", "--args", "backoffice_backend domain-events:rabbitmq:consume"]
+
   backoffice_frontend_server_java:
     container_name: codely-java_ddd_example-backoffice_frontend_server
     build:
@@ -68,6 +85,7 @@ services:
     volumes:
       - .:/app:delegated
       - backoffice_frontend_gradle_cache:/app/.gradle
+      - backoffice_frontend_build:/app/build
     depends_on:
       - shared_mysql
       - shared_rabbitmq
@@ -85,13 +103,37 @@ services:
     volumes:
       - .:/app:delegated
       - mooc_backend_gradle_cache:/app/.gradle
+      - mooc_backend_build:/app/build
     depends_on:
       - shared_mysql
       - shared_rabbitmq
       - backoffice_elasticsearch
     command: ["./gradlew", "bootRun", "--args", "mooc_backend server"]
 
+  mooc_backend_consumers_java:
+    container_name: codely-java_ddd_example-mooc_backend_consumers
+    build:
+      context: .
+      dockerfile: Dockerfile
+    restart: unless-stopped
+    volumes:
+      - .:/app:delegated
+      - mooc_consumers_gradle_cache:/app/.gradle
+      - mooc_consumers_build:/app/build
+    depends_on:
+      - shared_mysql
+      - shared_rabbitmq
+      - backoffice_elasticsearch
+    command: ["./gradlew", "bootRun", "--args", "mooc_backend domain-events:rabbitmq:consume"]
+
 volumes:
   backoffice_backend_gradle_cache:
+  backoffice_backend_build:
+  backoffice_consumers_gradle_cache:
+  backoffice_consumers_build:
   backoffice_frontend_gradle_cache:
+  backoffice_frontend_build:
   mooc_backend_gradle_cache:
+  mooc_backend_build:
+  mooc_consumers_gradle_cache:
+  mooc_consumers_build:

etc/http/publish_domain_events.http

@@ -9,7 +9,7 @@ Content-Type: application/json
       "type": "course.created",
       "occurred_on": "2023-11-14 10:00:00",
       "attributes": {
-        "id": "{{$random.uuid}}",
+        "id": "9bd0c98a-92cc-4a56-a5a1-7d40839ddc83",
         "name": "Demo course",
         "duration": "2 days"
       }
@@ -18,3 +18,24 @@ Content-Type: application/json
     }
   }
 }
+
+###
+POST http://localhost:8030/domain-events
+Content-Type: application/json
+
+{
+  "eventName": "course.renamed",
+  "eventRaw": {
+    "data": {
+      "id": "{{$random.uuid}}",
+      "type": "course.renamed",
+      "occurred_on": "2023-11-14 10:00:00",
+      "attributes": {
+        "id": "9bd0c98a-92cc-4a56-a5a1-7d40839ddc83",
+        "name": "heeey 22222"
+      }
+    },
+    "meta": {
+    }
+  }
+}

src/backoffice/main/tv/codely/backoffice/courses/application/rename/BackofficeCourseRenamer.java

@@ -1,5 +1,6 @@
 package tv.codely.backoffice.courses.application.rename;
 
+import tv.codely.backoffice.courses.domain.BackofficeCourseNotFound;
 import tv.codely.backoffice.courses.domain.BackofficeCourseRepository;
 import tv.codely.shared.domain.Service;
 
@@ -13,10 +14,13 @@ public BackofficeCourseRenamer(BackofficeCourseRepository repository) {
 
 	public void rename(String id, String name) {
 		this.repository.search(id)
-			.ifPresent(course -> {
-				course.rename(name);
+			.ifPresentOrElse(course -> {
+					course.rename(name);
 
-				this.repository.save(course);
-			});
+					this.repository.save(course);
+				},
+				() -> {
+					throw new BackofficeCourseNotFound(id);
+				});
 	}
 }

src/backoffice/main/tv/codely/backoffice/courses/application/rename/RenameBackofficeCourseOnCourseRenamed.java

@@ -3,11 +3,10 @@
 import org.springframework.context.event.EventListener;
 import tv.codely.shared.domain.Service;
 import tv.codely.shared.domain.bus.event.DomainEventSubscriber;
-import tv.codely.shared.domain.course.CourseCreatedDomainEvent;
 import tv.codely.shared.domain.course.CourseRenamedDomainEvent;
 
 @Service
-@DomainEventSubscriber({CourseCreatedDomainEvent.class})
+@DomainEventSubscriber({CourseRenamedDomainEvent.class})
 public final class RenameBackofficeCourseOnCourseRenamed {
 	private final BackofficeCourseRenamer renamer;
 

src/backoffice/main/tv/codely/backoffice/courses/domain/BackofficeCourseNotFound.java

@@ -0,0 +1,7 @@
+package tv.codely.backoffice.courses.domain;
+
+public class BackofficeCourseNotFound extends RuntimeException {
+	public BackofficeCourseNotFound(String id) {
+		super(String.format("The course <%s> doesn't exist", id));
+	}
+}

src/backoffice/main/tv/codely/backoffice/shared/infrastructure/persistence/BackofficeMySqlEventBusConfiguration.java

@@ -4,6 +4,7 @@
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
 import tv.codely.shared.infrastructure.bus.event.DomainEventsInformation;
 import tv.codely.shared.infrastructure.bus.event.mysql.MySqlDomainEventsConsumer;
 import tv.codely.shared.infrastructure.bus.event.mysql.MySqlEventBus;

src/mooc/test/tv/codely/mooc/shared/infrastructure/bus/event/rabbitmq/RabbitMqEventBusShould.java

@@ -46,7 +46,7 @@ void publish_and_consume_domain_events_from_rabbitmq() throws Exception {
 
         eventBus.publish(Collections.singletonList(domainEvent));
 
-        consumer.consume();
+        consumer.consume("mooc");
 
         eventually(() -> assertTrue(subscriber.hasBeenExecuted));
     }

src/shared/main/tv/codely/shared/domain/course/CourseRenamedDomainEvent.java

@@ -34,7 +34,7 @@ public CourseRenamedDomainEvent(
 
 	@Override
 	public String eventName() {
-		return "course.created";
+		return "course.renamed";
 	}
 
 	@Override