diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StatusUtil.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StatusUtil.java index 7f2220cb38ef..62add9525cf7 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StatusUtil.java +++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StatusUtil.java @@ -35,6 +35,7 @@ public static boolean isRetryable(Throwable error) { case INTERNAL: case CANCELLED: case RESOURCE_EXHAUSTED: + case ABORTED: return true; case UNAVAILABLE: if (statusRuntimeException.getMessage().contains("Server shutdownNow invoked")) {