We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 398f5cd commit 742e947Copy full SHA for 742e947
1 file changed
google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Subscriber.java
@@ -409,8 +409,9 @@ private void stopConnections(List<? extends ApiService> connections) {
409
try {
410
subscriber.awaitTerminated();
411
} catch (IllegalStateException e) {
412
- // It is expected for some connections to be already in state failed so stop will
413
- // throw this expection.
+ // If the service fails, awaitTerminated will throw an exception.
+ // However, we could be stopping services because at least one
414
+ // has already failed, so we just ignore this exception.
415
}
416
417
0 commit comments