Skip to content

Commit 432d8c8

Browse files
authored
---
yaml --- r: 5407 b: refs/heads/master c: 9fa3b3e h: refs/heads/master i: 5405: 61ff685 5403: ea8bd78 5399: caefa34 5391: 0ec83a6 5375: 77bcf4a
1 parent 695c5a3 commit 432d8c8

2 files changed

Lines changed: 2 additions & 1 deletion

File tree

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
---
2-
refs/heads/master: 461aa54b3008ed2e2188ff44f718ce50f804d4d4
2+
refs/heads/master: 9fa3b3ea83e0ba3b7d192f000a5d6a5860d90937
33
refs/heads/travis: dae77e558b884bc1b165155482d76c8e40b0fca4
44
refs/heads/gh-pages: 229631582f8957646f81e92ae5a326504f48ee5b
55
refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444

trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PollingSubscriberConnection.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -185,6 +185,7 @@ public void run() {
185185
TimeUnit.MILLISECONDS);
186186
return;
187187
}
188+
messageDispatcher.stop();
188189
notifyFailed(cause);
189190
}
190191
});

0 commit comments

Comments
 (0)