From 04f95f488af294b495553af03cb456043c03fdb2 Mon Sep 17 00:00:00 2001
From: LM <lemai>
Date: Fri, 10 Jan 2020 16:34:49 -0800
Subject: [PATCH] pubsub sample needs update for listener interface

---
 .../main/java/io/dapr/examples/pubsub/http/Subscriber.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 b0c8cdf054..1d88ffe056 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 static void main(String[] args) throws Exception {
     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()));