Skip to content

Commit 66e879e

Browse files
deps: update dependency com.google.cloud:google-cloud-pubsublite to v0.16.0 (#202)
* update * update
1 parent 3a77dd1 commit 66e879e

File tree

4 files changed

+5
-7
lines changed

4 files changed

+5
-7
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@
4343
<dependency>
4444
<groupId>com.google.cloud</groupId>
4545
<artifactId>google-cloud-pubsublite</artifactId>
46-
<version>0.15.0</version>
46+
<version>0.16.0</version>
4747
</dependency>
4848
<dependency>
4949
<groupId>com.google.api.grpc</groupId>

samples/snapshot/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@
4444
<dependency>
4545
<groupId>com.google.cloud</groupId>
4646
<artifactId>google-cloud-pubsublite</artifactId>
47-
<version>0.14.2</version>
47+
<version>0.16.0</version>
4848
</dependency>
4949
<dependency>
5050
<groupId>junit</groupId>

samples/snippets/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@
4444
<dependency>
4545
<groupId>com.google.cloud</groupId>
4646
<artifactId>google-cloud-pubsublite</artifactId>
47-
<version>0.14.2</version>
47+
<version>0.16.0</version>
4848
</dependency>
4949
<dependency>
5050
<groupId>junit</groupId>

src/main/java/com/google/cloud/pubsublite/spark/internal/PartitionSubscriberFactory.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,14 +21,12 @@
2121
import com.google.cloud.pubsublite.Partition;
2222
import com.google.cloud.pubsublite.SequencedMessage;
2323
import com.google.cloud.pubsublite.internal.wire.Subscriber;
24-
import com.google.common.collect.ImmutableList;
2524
import java.io.Serializable;
25+
import java.util.List;
2626
import java.util.function.Consumer;
2727

2828
public interface PartitionSubscriberFactory extends Serializable {
2929
Subscriber newSubscriber(
30-
Partition partition,
31-
Offset offset,
32-
Consumer<ImmutableList<SequencedMessage>> message_consumer)
30+
Partition partition, Offset offset, Consumer<List<SequencedMessage>> message_consumer)
3331
throws ApiException;
3432
}

0 commit comments

Comments
 (0)