feat: Add endpoint examples.

dapr · Apr 24, 2023 · a8714d5 · a8714d5
1 parent 358af42
commit a8714d5
Showing 1 changed file with 28 additions and 3 deletions.
diff --git a/examples/src/main/java/io/dapr/examples/pubsub/SubscriberController.java b/examples/src/main/java/io/dapr/examples/pubsub/SubscriberController.java
@@ -39,9 +39,10 @@ public class SubscriberController {
 
   private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
 
+
   /**
    * Handles a registered publish endpoint on this app.
-   * 
+   *
    * @param cloudEvent The cloud event received.
    * @return A message containing the time.
    */
@@ -58,6 +59,27 @@ public Mono<Void> handleMessage(@RequestBody(required = false) CloudEvent<String
     });
   }
 
+
+  /**
+   * Handles a registered publish endpoint on this app adding a topic which manage to forward undeliverable messages.
+   * 
+   * @param cloudEvent The cloud event received.
+   * @return A message containing the time.
+   */
+  @Topic(name = "testingtopic", pubsubName = "${myAppProperty:messagebus}",
+      deadLetterTopic = "${deadLetterProperty:deadTopic}")
+  @PostMapping(path = "/testingtopic")
+  public Mono<Void> handleMessageWithErrorHandler(@RequestBody(required = false) CloudEvent<String> cloudEvent) {
+    return Mono.fromRunnable(() -> {
+      try {
+        System.out.println("Subscriber got: " + cloudEvent.getData());
+        System.out.println("Subscriber got: " + OBJECT_MAPPER.writeValueAsString(cloudEvent));
+      } catch (Exception e) {
+        throw new RuntimeException(e);
+      }
+    });
+  }
+
   /**
    * Handles a registered publish endpoint on this app (version 2 of a cloud
    * event).
@@ -66,6 +88,7 @@ public Mono<Void> handleMessage(@RequestBody(required = false) CloudEvent<String
    * @return A message containing the time.
    */
   @Topic(name = "testingtopic", pubsubName = "${myAppProperty:messagebus}",
+      deadLetterTopic = "${deadLetterProperty:deadTopic}",
           rule = @Rule(match = "event.type == \"v2\"", priority = 1))
   @PostMapping(path = "/testingtopicV2")
   public Mono<Void> handleMessageV2(@RequestBody(required = false) CloudEvent cloudEvent) {
@@ -84,7 +107,8 @@ public Mono<Void> handleMessageV2(@RequestBody(required = false) CloudEvent clou
    * @param cloudEvent The cloud event received.
    * @return A message containing the time.
    */
-  @Topic(name = "bulkpublishtesting", pubsubName = "${myAppProperty:messagebus}")
+  @Topic(name = "bulkpublishtesting", pubsubName = "${myAppProperty:messagebus}",
+      deadLetterTopic = "${deadLetterProperty:deadTopic}")
   @PostMapping(path = "/bulkpublishtesting")
   public Mono<Void> handleBulkPublishMessage(@RequestBody(required = false) CloudEvent cloudEvent) {
     return Mono.fromRunnable(() -> {
@@ -104,7 +128,8 @@ public Mono<Void> handleBulkPublishMessage(@RequestBody(required = false) CloudE
    * @return A list of responses for each event.
    */
   @BulkSubscribe()
-  @Topic(name = "testingtopicbulk", pubsubName = "${myAppProperty:messagebus}")
+  @Topic(name = "testingtopicbulk", pubsubName = "${myAppProperty:messagebus}",
+      deadLetterTopic = "${deadLetterProperty:deadTopic}")
   @PostMapping(path = "/testingtopicbulk")
   public Mono<BulkSubscribeAppResponse> handleBulkMessage(
       @RequestBody(required = false) BulkSubscribeMessage<CloudEvent<String>> bulkMessage) {