Apply pull request suggestions

Signed-off-by: Matheus Cruz <[email protected]>

Author: mcruzdev

sdk-tests/src/test/java/io/dapr/it/testcontainers/pubsub/outbox/ProductWebhookController.java

@@ -19,18 +19,18 @@
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
 
 @RestController
 @RequestMapping("/webhooks/products")
 public class ProductWebhookController {
 
-  public static final List<CloudEvent<Product>> EVENT_LIST = new ArrayList<>();
+  public static final List<CloudEvent<Product>> EVENT_LIST = new CopyOnWriteArrayList<>();
 
   @PostMapping("/created")
   @Topic(name = "product.created", pubsubName = "pubsub")
-  public void handleProductCreated(@RequestBody CloudEvent cloudEvent) {
+  public void handleEvent(@RequestBody CloudEvent cloudEvent) {
     System.out.println("Received product.created event: " + cloudEvent.getData());
     EVENT_LIST.add(cloudEvent);
   }

spring-boot-examples/producer-app/src/main/java/io/dapr/springboot/examples/producer/OrderDTO.java

@@ -0,0 +1,31 @@
+package io.dapr.springboot.examples.producer;
+
+public class OrderDTO {
+
+  private String id;
+  private String item;
+  private Integer amount;
+
+  public OrderDTO() {
+  }
+
+  public OrderDTO(String id, String item, Integer amount) {
+    this.id = id;
+    this.item = item;
+    this.amount = amount;
+  }
+
+  public String getId() {
+    return id;
+  }
+
+
+  public String getItem() {
+    return item;
+  }
+
+  public Integer getAmount() {
+    return amount;
+  }
+
+}

spring-boot-examples/producer-app/src/test/java/io/dapr/springboot/examples/producer/ProducerAppIT.java

@@ -75,8 +75,10 @@ void cleanUp() {
 
   @Test
   void testOrdersOutboxEndpointAndMessaging() {
+    OrderDTO order = new OrderDTO("outbox-order-123", "Lorem ipsum", 1000);
+
     given().contentType(ContentType.JSON)
-        .body("{ \"id\": \"outbox-order-123\",\"item\": \"Lorem ipsum\",\"amount\": 1000}")
+        .body(order)
         .when()
         .post("/orders/outbox")
         .then()
@@ -88,10 +90,10 @@ void testOrdersOutboxEndpointAndMessaging() {
   }
 
   @Test
-  void testOrdersEndpointAndMessaging() throws InterruptedException, IOException {
-
+  void testOrdersEndpointAndMessaging() {
+    OrderDTO order = new OrderDTO("abc-123", "the mars volta LP", 1);
     given().contentType(ContentType.JSON)
-            .body("{ \"id\": \"abc-123\",\"item\": \"the mars volta LP\",\"amount\": 1}")
+            .body(order)
             .when()
             .post("/orders")
             .then()
@@ -137,7 +139,7 @@ void testOrdersEndpointAndMessaging() throws InterruptedException, IOException {
   }
 
   @Test
-  void testCustomersWorkflows() throws InterruptedException, IOException {
+  void testCustomersWorkflows() {
 
     given().contentType(ContentType.JSON)
             .body("{\"customerName\": \"salaboy\"}")