From 3140ad3c1ce75311cc8d8dc1172157ec75abd35f Mon Sep 17 00:00:00 2001 From: Michael Jiang Date: Tue, 16 Feb 2021 15:31:40 -0500 Subject: [PATCH] update --- samples/snapshot/pom.xml | 2 +- samples/snippets/pom.xml | 2 +- .../snippets/src/main/java/pubsublite/spark/AdminUtils.java | 6 +++--- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml index 33630cbb..31033d43 100644 --- a/samples/snapshot/pom.xml +++ b/samples/snapshot/pom.xml @@ -44,7 +44,7 @@ com.google.cloud google-cloud-pubsublite - 0.8.0 + 0.10.0 junit diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml index 101ed665..b501a810 100644 --- a/samples/snippets/pom.xml +++ b/samples/snippets/pom.xml @@ -44,7 +44,7 @@ com.google.cloud google-cloud-pubsublite - 0.8.0 + 0.10.0 junit diff --git a/samples/snippets/src/main/java/pubsublite/spark/AdminUtils.java b/samples/snippets/src/main/java/pubsublite/spark/AdminUtils.java index 8a284905..09bac836 100644 --- a/samples/snippets/src/main/java/pubsublite/spark/AdminUtils.java +++ b/samples/snippets/src/main/java/pubsublite/spark/AdminUtils.java @@ -24,8 +24,8 @@ import com.google.cloud.pubsublite.AdminClientSettings; import com.google.cloud.pubsublite.CloudRegion; import com.google.cloud.pubsublite.CloudZone; +import com.google.cloud.pubsublite.MessageMetadata; import com.google.cloud.pubsublite.ProjectNumber; -import com.google.cloud.pubsublite.PublishMetadata; import com.google.cloud.pubsublite.SubscriptionName; import com.google.cloud.pubsublite.SubscriptionPath; import com.google.cloud.pubsublite.TopicName; @@ -193,11 +193,11 @@ public static void publisherExample( futures.add(future); } } finally { - ArrayList metadata = new ArrayList<>(); + ArrayList metadata = new ArrayList<>(); List ackIds = ApiFutures.allAsList(futures).get(); for (String id : ackIds) { // Decoded metadata contains partition and offset. - metadata.add(PublishMetadata.decode(id)); + metadata.add(MessageMetadata.decode(id)); } System.out.println(metadata + "\nPublished " + ackIds.size() + " messages.");