Skip to content

Commit 742e947

Browse files
committed
pr comment
1 parent 398f5cd commit 742e947

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

  • google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -409,8 +409,9 @@ private void stopConnections(List<? extends ApiService> connections) {
409409
try {
410410
subscriber.awaitTerminated();
411411
} catch (IllegalStateException e) {
412-
// It is expected for some connections to be already in state failed so stop will
413-
// throw this expection.
412+
// If the service fails, awaitTerminated will throw an exception.
413+
// However, we could be stopping services because at least one
414+
// has already failed, so we just ignore this exception.
414415
}
415416
}
416417
}

0 commit comments

Comments
 (0)