---

pongad · web-flow · commit 3f1b79b9580d · 2017-10-10T06:19:00.000+11:00
yaml --- r: 8433 b: refs/heads/master c: 540734e h: refs/heads/master i: 8431: 85eb081
diff --git a/[refs] b/[refs]
@@ -1,5 +1,5 @@
 ---
-refs/heads/master: ddcaaab56fdd46d9a998ae55b1cc34474dad36f0
+refs/heads/master: 540734e6e9bce69f47854d2aabfbe61f1ac53631
 refs/heads/travis: 47e4fee4fd5af9b2a8ce46f23c72ec95f9b195b2
 refs/heads/gh-pages: 3e16a39145437096333db5811e5c0292719c1823
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java b/trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java
@@ -229,11 +229,12 @@ public void onFailure(Throwable cause) {
               logger.log(Level.FINE, "pull failure after service no longer running", cause);
               return;
             }
-            logger.log(Level.WARNING, "Terminated streaming with exception", cause);
             if (!StatusUtil.isRetryable(cause)) {
+              logger.log(Level.SEVERE, "terminated streaming with exception", cause);
               notifyFailed(cause);
               return;
             }
+            logger.log(Level.FINE, "stream closed with retryable exception; will reconnect", cause);
             long backoffMillis = channelReconnectBackoffMillis.get();
             long newBackoffMillis =
                 Math.min(backoffMillis * 2, MAX_CHANNEL_RECONNECT_BACKOFF.toMillis());

Original file line number	Diff line number	Diff line change
`@@ -229,11 +229,12 @@ public void onFailure(Throwable cause) {`
`229`	`229`	`logger.log(Level.FINE, "pull failure after service no longer running", cause);`
`230`	`230`	`return;`
`231`	`231`	`}`
`232`		`- logger.log(Level.WARNING, "Terminated streaming with exception", cause);`
`233`	`232`	`if (!StatusUtil.isRetryable(cause)) {`
	`233`	`+ logger.log(Level.SEVERE, "terminated streaming with exception", cause);`
`234`	`234`	`notifyFailed(cause);`
`235`	`235`	`return;`
`236`	`236`	`}`
	`237`	`+ logger.log(Level.FINE, "stream closed with retryable exception; will reconnect", cause);`
`237`	`238`	`long backoffMillis = channelReconnectBackoffMillis.get();`
`238`	`239`	`long newBackoffMillis =`
`239`	`240`	`Math.min(backoffMillis * 2, MAX_CHANNEL_RECONNECT_BACKOFF.toMillis());`