feat : connecting to postgres for modulith tests

kafka-sample/spring-modulith-outbox-pattern/pom.xml

@@ -144,11 +144,6 @@
  <artifactId>postgresql</artifactId>
  <scope>test</scope>
  </dependency>
- <dependency>
- <groupId>com.h2database</groupId>
- <artifactId>h2</artifactId>
- <scope>test</scope>
- </dependency>
  </dependencies>
 
  <dependencyManagement>

kafka-sample/spring-modulith-outbox-pattern/src/main/java/com/example/outboxpattern/config/GlobalExceptionHandler.java → kafka-sample/spring-modulith-outbox-pattern/src/main/java/com/example/outboxpattern/exception/GlobalExceptionHandler.java

@@ -1,6 +1,5 @@
-package com.example.outboxpattern.config;
+package com.example.outboxpattern.exception;
 
-import com.example.outboxpattern.exception.ResourceNotFoundException;
 import java.net.URI;
 import java.time.Instant;
 import java.util.Comparator;

kafka-sample/spring-modulith-outbox-pattern/src/main/java/com/example/outboxpattern/order/internal/entities/Order.java

@@ -1,6 +1,15 @@
 package com.example.outboxpattern.order.internal.entities;
 
-import jakarta.persistence.*;
+import jakarta.persistence.CascadeType;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.OneToMany;
+import jakarta.persistence.Table;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;

kafka-sample/spring-modulith-outbox-pattern/src/main/java/com/example/outboxpattern/order/internal/request/OrderItemRequest.java

@@ -1,7 +1,10 @@
 package com.example.outboxpattern.order.internal.request;
 
 import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Positive;
 import java.math.BigDecimal;
 
 public record OrderItemRequest(
- @NotBlank(message = "Product cannot be blank") String productCode, BigDecimal productPrice, int quantity) {}
+ @NotBlank(message = "Product cannot be blank") String productCode,
+ BigDecimal productPrice,
+ @Positive(message = "quantity cant be 0 or negative") Integer quantity) {}

kafka-sample/spring-modulith-outbox-pattern/src/main/java/com/example/outboxpattern/producer/Producer.java

@@ -14,8 +14,9 @@
 public class Producer {
 
  @ApplicationModuleListener
- void onOrderResponseEvent(OrderRecord event) {
- publish(event.id());
+ void onOrderResponseEvent(OrderRecord orderRecord) {
+ log.info("Received Event :{}", orderRecord);
+ publish(orderRecord.id());
  }
 
  private void publish(Long orderId) {

kafka-sample/spring-modulith-outbox-pattern/src/test/java/com/example/outboxpattern/order/internal/OrderModuleTests.java → kafka-sample/spring-modulith-outbox-pattern/src/test/java/com/example/outboxpattern/order/internal/OrderModuleIntTests.java

@@ -4,6 +4,7 @@
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.Mockito.when;
 
+import com.example.outboxpattern.common.ContainersConfig;
 import com.example.outboxpattern.order.OrderRecord;
 import com.example.outboxpattern.order.internal.request.OrderItemRequest;
 import com.example.outboxpattern.order.internal.request.OrderRequest;
@@ -14,14 +15,16 @@
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.mock.mockito.MockBean;
+import org.springframework.context.annotation.Import;
 import org.springframework.kafka.core.KafkaOperations;
 import org.springframework.kafka.support.SendResult;
 import org.springframework.modulith.test.ApplicationModuleTest;
 import org.springframework.modulith.test.Scenario;
 
 @Slf4j
 @ApplicationModuleTest
-class OrderModuleTests {
+@Import(ContainersConfig.class)
+class OrderModuleIntTests {
 
  @MockBean
  KafkaOperations<?, ?> kafkaOperations;