---

chenyumic · web-flow · commit f13ec83576bb · 2018-05-08T15:04:25.000-07:00
yaml --- r: 9621 b: refs/heads/michaelawyu-patch-1 c: 44849f3 h: refs/heads/master i: 9619: d4286d2
diff --git a/[refs] b/[refs]
@@ -97,4 +97,4 @@ refs/tags/v0.45.0: 4b4eb52d0823f5335cb8acf54a88bae199e013ae
 refs/tags/v0.46.0: 40dfc83a11b2cf2c21bf0f5a7b1e47087cbf0259
 refs/heads/proto-grpc-refactoring-rollback: 6094a5b7427538fde31e25bf028bc91a4d9769ab
 refs/heads/alixhami-patch-1: 277eebc2d3abd73fa376a1d6f39fcb93a9f0335d
-refs/heads/michaelawyu-patch-1: f1ac84a429f163688fcd32ed2179f708456fbabe
+refs/heads/michaelawyu-patch-1: 44849f3fcbfec21bc0c047fbea5b3fad6ee3f92a
diff --git a/branches/michaelawyu-patch-1/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/CreateTopicAndPublishMessages.java b/branches/michaelawyu-patch-1/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/CreateTopicAndPublishMessages.java
@@ -97,7 +97,7 @@ public static void publishMessagesWithErrorHandler() throws Exception {
         ApiFuture<String> future = publisher.publish(pubsubMessage);
 
         // Add an asynchronous callback to handle success / failure
-        ApiFuture.addCallback(future, newApiFutureCallback<String>()) {
+        ApiFuture.addCallback(future, new ApiFutureCallback<String>() {
 
           @Override
           public void onFailure(Throwable throwable) {
@@ -115,7 +115,7 @@ public void onSuccess(String messageId) {
             // Once published, returns server-assigned message ids (unique within the topic)
             System.out.println(messageId);
           }
-        }
+        });
       }
     } finally {
       if (publisher != null) {
