eugenp · lor6 · May 16, 2025 · Apr 10, 2025 · Apr 14, 2025 · Apr 14, 2025
diff --git a/messaging-modules/dapr/dapr-publisher/pom.xml b/messaging-modules/dapr/dapr-publisher/pom.xml
@@ -0,0 +1,57 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>com.baeldung.dapr</groupId>
+        <artifactId>dapr</artifactId>
+        <version>0.0.1-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>dapr-publisher</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-actuator</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.dapr.spring</groupId>
+            <artifactId>dapr-spring-boot-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.dapr.spring</groupId>
+            <artifactId>dapr-spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>rabbitmq</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.rest-assured</groupId>
+            <artifactId>rest-assured</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>21</source>
+                    <target>21</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
diff --git a/...modules/dapr/dapr-publisher/src/main/java/com/baeldung/dapr/pubsub/model/RideRequest.java b/...modules/dapr/dapr-publisher/src/main/java/com/baeldung/dapr/pubsub/model/RideRequest.java
@@ -0,0 +1,45 @@
+package com.baeldung.dapr.pubsub.model;
+
+public class RideRequest {
+    private String passengerId;
+    private String location;
+    private String destination;
+
+    public RideRequest() {
+    }
+
+    public RideRequest(String passengerId, String location, String destination) {
+        this.passengerId = passengerId;
+        this.location = location;
+        this.destination = destination;
+    }
+
+    public String getPassengerId() {
+        return passengerId;
+    }
+
+    public void setPassengerId(String passengerId) {
+        this.passengerId = passengerId;
+    }
+
+    public String getLocation() {
+        return location;
+    }
+
+    public void setLocation(String location) {
+        this.location = location;
+    }
+
+    public String getDestination() {
+        return destination;
+    }
+
+    public void setDestination(String destination) {
+        this.destination = destination;
+    }
+
+    @Override
+    public String toString() {
+        return "RideRequest [passengerId=" + passengerId + ", location=" + location + ", destination=" + destination + "]";
+    }
+}
diff --git a/.../dapr-publisher/src/main/java/com/baeldung/dapr/pubsub/publisher/DaprMessagingConfig.java b/.../dapr-publisher/src/main/java/com/baeldung/dapr/pubsub/publisher/DaprMessagingConfig.java
@@ -0,0 +1,21 @@
+package com.baeldung.dapr.pubsub.publisher;
+
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import com.baeldung.dapr.pubsub.model.RideRequest;
+
+import io.dapr.client.DaprClient;
+import io.dapr.spring.boot.autoconfigure.pubsub.DaprPubSubProperties;
+import io.dapr.spring.messaging.DaprMessagingTemplate;
+
+@Configuration
+@EnableConfigurationProperties({ DaprPubSubProperties.class })
+public class DaprMessagingConfig {
+
+    @Bean
+    public DaprMessagingTemplate<RideRequest> messagingTemplate(DaprClient client, DaprPubSubProperties config) {
+        return new DaprMessagingTemplate<>(client, config.getName(), false);
+    }
+}
diff --git a/...apr/dapr-publisher/src/main/java/com/baeldung/dapr/pubsub/publisher/DaprPublisherApp.java b/...apr/dapr-publisher/src/main/java/com/baeldung/dapr/pubsub/publisher/DaprPublisherApp.java
@@ -0,0 +1,12 @@
+package com.baeldung.dapr.pubsub.publisher;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class DaprPublisherApp {
+
+    public static void main(String[] args) {
+        SpringApplication.run(DaprPublisherApp.class, args);
+    }
+}
diff --git a/...r-publisher/src/main/java/com/baeldung/dapr/pubsub/publisher/PassengerRestController.java b/...r-publisher/src/main/java/com/baeldung/dapr/pubsub/publisher/PassengerRestController.java
@@ -0,0 +1,34 @@
+package com.baeldung.dapr.pubsub.publisher;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.baeldung.dapr.pubsub.model.RideRequest;
+
+import io.dapr.spring.messaging.DaprMessagingTemplate;
+
+@RestController
+@RequestMapping("/passenger")
+public class PassengerRestController {
+
+    private static final Logger logger = LoggerFactory.getLogger(PassengerRestController.class);
+    public static final String RIDE_REQUESTS_TOPIC = "ride-requests";
+
+    private DaprMessagingTemplate<RideRequest> messaging;
+
+    public PassengerRestController(DaprMessagingTemplate<RideRequest> messaging) {
+        this.messaging = messaging;
+    }
+
+    @PostMapping("/request-ride")
+    public String requestRide(@RequestBody RideRequest request) {
+        messaging.send(RIDE_REQUESTS_TOPIC, request);
+
+        logger.info("[bael] message sent: {}", request);
+        return "waiting for drivers";
+    }
+}
diff --git a/messaging-modules/dapr/dapr-publisher/src/main/resources/application.properties b/messaging-modules/dapr/dapr-publisher/src/main/resources/application.properties
@@ -0,0 +1,2 @@
+spring.application.name=dapr-publisher
+dapr.pubsub.name=ride-hailing
diff --git a/...lisher/src/test/java/com/baeldung/dapr/pubsub/publisher/DaprPublisherIntegrationTest.java b/...lisher/src/test/java/com/baeldung/dapr/pubsub/publisher/DaprPublisherIntegrationTest.java
@@ -0,0 +1,98 @@
+package com.baeldung.dapr.pubsub.publisher;
+
+import static io.restassured.RestAssured.given;
+import static org.awaitility.Awaitility.await;
+import static org.hamcrest.Matchers.equalTo;
+import static org.hamcrest.Matchers.greaterThan;
+import static org.hamcrest.Matchers.is;
+
+import java.time.Duration;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.testcontainers.Testcontainers;
+import org.testcontainers.containers.wait.strategy.Wait;
+
+import io.dapr.springboot.DaprAutoConfiguration;
+import io.dapr.testcontainers.DaprContainer;
+import io.restassured.RestAssured;
+import io.restassured.http.ContentType;
+
+@SpringBootTest(classes = { DaprPublisherTestApp.class, DaprTestContainersConfig.class, DaprAutoConfiguration.class }, webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT)
+class DaprPublisherIntegrationTest {
+
+    private static final Logger logger = LoggerFactory.getLogger(DaprPublisherIntegrationTest.class);
+    private static final String READY_MESSAGE_PATTERN = ".*app is subscribed to the following topics.*";
+
+    @Autowired
+    DriverRestController controller;
+
+    @Autowired
+    DaprContainer daprContainer;
+
+    @Value("${server.port}")
+    int serverPort;
+
+    @Value("${driver.acceptance.criteria}")
+    String criteria;
+
+    @BeforeEach
+    void setUp() {
+        logger.info("[bael] test setup");
+
+        RestAssured.baseURI = "http://localhost:" + serverPort;
+        Testcontainers.exposeHostPorts(serverPort);
+
+        logger.info("[bael] waiting for ready...");
+        Wait.forLogMessage(READY_MESSAGE_PATTERN, 1)
+            .waitUntilReady(daprContainer);
+        logger.info("[bael] ready.");
+    }
+
+    @Test
+    void whenDriveUnacceptable_thenDrivesAcceptedIncrease() {
+        int drivesAccepted = controller.getDrivesAccepted();
+
+        given().contentType(ContentType.JSON)
+            .body("""
+                {
+                "passengerId": "1",
+                "location": "Point A",
+                "destination": "%s Point B"
+                }
+                """.formatted(criteria))
+            .when()
+            .post("/passenger/request-ride")
+            .then()
+            .statusCode(200);
+
+        await().atMost(Duration.ofSeconds(5))
+            .until(controller::getDrivesAccepted, is(equalTo(drivesAccepted + 1)));
+    }
+
+    @Test
+    void whenDriveAcceptable_thenDrivesRejectedIncrease() {
+        int drivesRejected = controller.getDrivesRejected();
+
+        given().contentType(ContentType.JSON)
+            .body("""
+                {
+                "passengerId": "2",
+                "location": "Point B",
+                "destination": "West Side A"
+                }
+                """)
+            .when()
+            .post("/passenger/request-ride")
+            .then()
+            .statusCode(200);
+
+        await().atMost(Duration.ofSeconds(5))
+            .until(controller::getDrivesRejected, greaterThan(drivesRejected));
+    }
+}
diff --git a/...dapr-publisher/src/test/java/com/baeldung/dapr/pubsub/publisher/DaprPublisherTestApp.java b/...dapr-publisher/src/test/java/com/baeldung/dapr/pubsub/publisher/DaprPublisherTestApp.java
@@ -0,0 +1,21 @@
+package com.baeldung.dapr.pubsub.publisher;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.SpringApplication.Running;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.testcontainers.Testcontainers;
+
+@SpringBootApplication
+public class DaprPublisherTestApp {
+
+    public static void main(String[] args) {
+        Running app = SpringApplication.from(DaprPublisherApp::main)
+            .with(DaprTestContainersConfig.class)
+            .run(args);
+
+        int port = app.getApplicationContext()
+            .getEnvironment()
+            .getProperty("server.port", Integer.class);
+        Testcontainers.exposeHostPorts(port);
+    }
+}
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		spring.application.name=dapr-publisher
		dapr.pubsub.name=ride-hailing