Skip to content

Commit ac63d4e

Browse files
authored
---
yaml --- r: 7799 b: refs/heads/tswast-patch-1 c: f91c809 h: refs/heads/master i: 7797: 3c23da1 7795: 93f2edf 7791: 955d3f9
1 parent 3211458 commit ac63d4e

4 files changed

Lines changed: 371 additions & 239 deletions

File tree

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,5 +57,5 @@ refs/tags/v0.18.0: 9d193c4c4b9d1c6f21515dd8e50836b9194ec9bb
5757
refs/tags/v0.19.0: e67b56e4d8dad5f9a7b38c9b2107c23c828f2ed5
5858
refs/tags/v0.20.0: 839f7fb7156535146aa1cb2c5aadd8d375d854e8
5959
refs/tags/v0.20.1: 370471f437f1f4f68a11e068df5cd6bf39edb1fa
60-
refs/heads/tswast-patch-1: c68968b92233e34245ffd3bec66c57f07992d249
60+
refs/heads/tswast-patch-1: f91c80943012cded85e38702a82ab4efbda7e0c5
6161
refs/heads/pubsub-streaming-pull: 19262b752ee874eb2ca3b950eb2aef44d5a5267b

branches/tswast-patch-1/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/CreateSubscriptionAndPullMessages.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,9 +54,9 @@ public ListenableFuture<MessageReceiver.AckReply> receiveMessage(PubsubMessage m
5454
try {
5555
subscriber = Subscriber.Builder.newBuilder(subscription, receiver).build();
5656
subscriber.addListener(
57-
new Service.Listener() {
57+
new Subscriber.SubscriberListener() {
5858
@Override
59-
public void failed(Service.State from, Throwable failure) {
59+
public void failed(Subscriber.State from, Throwable failure) {
6060
System.err.println(failure);
6161
}
6262
},

0 commit comments

Comments
 (0)