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.");