From 110177ee636e32606cc93d6b8477d78e11ae464e Mon Sep 17 00:00:00 2001 From: jiangmichaellll <40044148+jiangmichaellll@users.noreply.github.com> Date: Tue, 16 Feb 2021 15:47:53 -0500 Subject: [PATCH] deps: update dependency com.google.cloud:google-cloud-pubsublite to v0.10.0 (#81) --- 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 b5578f6f..f730fc6b 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 84552347..71096938 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.");