updating logs

dapr · Feb 11, 2025 · aef4814 · aef4814
1 parent c82c75d
commit aef4814
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 3 deletions.
diff --git a/...-boot-examples/producer-app/src/main/java/io/dapr/springboot/examples/producer/Order.java b/...-boot-examples/producer-app/src/main/java/io/dapr/springboot/examples/producer/Order.java
@@ -48,4 +48,9 @@ public Integer getAmount() {
   public void setAmount(Integer amount) {
     this.amount = amount;
   }
+
+  @Override
+  public String toString() {
+    return "Order{" + "id='" + id + '\'' + ", item='" + item + '\'' + ", amount=" + amount + '}';
+  }
 }
diff --git a/...producer-app/src/main/java/io/dapr/springboot/examples/producer/OrdersRestController.java b/...producer-app/src/main/java/io/dapr/springboot/examples/producer/OrdersRestController.java
@@ -36,6 +36,10 @@ public class OrdersRestController {
   @Autowired
   private DaprMessagingTemplate<Order> messagingTemplate;
 
+  /**
+   * Store orders from customers.
+   * @param order from the customer
+   */
   @PostMapping("/orders")
   public void storeOrder(@RequestBody Order order) {
     logger.info("Storing Order: " + order);

diff --git a/...src/main/java/io/dapr/springboot/examples/producer/workflow/CustomerFollowupActivity.java b/...src/main/java/io/dapr/springboot/examples/producer/workflow/CustomerFollowupActivity.java
@@ -39,7 +39,7 @@ public Object run(WorkflowActivityContext ctx) {
     customer = customerStore.getCustomer(customer.getCustomerName());
     customer.setFollowUp(true);
     customerStore.addCustomer(customer);
-    logger.info("Customer: " + customer.getCustomerName() + " follow-up.");
+    logger.info("Customer: " + customer.getCustomerName() + " follow-up done.");
     return customer;
   }
 

diff --git a/...-app/src/test/java/io/dapr/springboot/examples/producer/TestSubscriberRestController.java b/...-app/src/test/java/io/dapr/springboot/examples/producer/TestSubscriberRestController.java
@@ -2,6 +2,8 @@
 
 import io.dapr.Topic;
 import io.dapr.client.domain.CloudEvent;
+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.RestController;
@@ -14,12 +16,12 @@ public class TestSubscriberRestController {
 
   private List<CloudEvent> events = new ArrayList<>();
 
+  private final Logger logger = LoggerFactory.getLogger(TestSubscriberRestController.class);
 
   @PostMapping("subscribe")
   @Topic(pubsubName = "pubsub", name = "topic")
   public void subscribe(@RequestBody CloudEvent<Order> cloudEvent){
-    System.out.println("CONSUME +++++ " + cloudEvent);
-    System.out.println("ORDER +++++ " + cloudEvent.getData());
+    logger.info("Order Event Received: " + cloudEvent.getData());
     events.add(cloudEvent);
   }