diff --git a/examples/src/main/java/io/dapr/examples/pubsub/http/Subscriber.java b/examples/src/main/java/io/dapr/examples/pubsub/http/Subscriber.java
index b0c8cdf05..1d88ffe05 100644
--- a/examples/src/main/java/io/dapr/examples/pubsub/http/Subscriber.java
+++ b/examples/src/main/java/io/dapr/examples/pubsub/http/Subscriber.java
@@ -35,9 +35,9 @@ public class Subscriber {
     int port = Integer.parseInt(cmd.getOptionValue("port"));
 
     // Subscribe to topic.
-    Dapr.getInstance().subscribeToTopic("message", (id, dataType, data, metadata) -> Mono
+    Dapr.getInstance().subscribeToTopic("message", (envelope, metadata) -> Mono
         .fromSupplier(() -> {
-          System.out.println("Subscriber got message (" + id + "): " + (data == null ? "" : new String(data)));
+          System.out.println("Subscriber got message: " + (envelope.getData() == null ? "" : new String(envelope.getData())));
           return Boolean.TRUE;
         })
         .then(Mono.empty()));