File tree Expand file tree Collapse file tree 4 files changed +9
-4
lines changed
google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1 Expand file tree Collapse file tree 4 files changed +9
-4
lines changed Original file line number Diff line number Diff line change @@ -41,6 +41,7 @@ deep-preserve-regex:
4141- " /google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SequentialExecutorServiceTest.java"
4242- " /google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/StatusUtilTest.java"
4343- " /google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnectionTest.java"
44+ - " /google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriberShutdownSettingsTest.java"
4445- " /google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriberTest.java"
4546- " /google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminSmokeTest.java"
4647- " /google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/WaiterTest.java"
@@ -64,6 +65,7 @@ deep-preserve-regex:
6465- " /google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java"
6566- " /google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java"
6667- " /google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriberInterface.java"
68+ - " /google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriberShutdownSettings.java"
6769- " /google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriberStats.java"
6870- " /google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Waiter.java"
6971
Original file line number Diff line number Diff line change 2626 # the branch into which the pull request is merged
2727 base_branch : main
2828 steps :
29- - uses : actions/checkout@v5
29+ - uses : actions/checkout@v4
3030 with :
3131 fetch-depth : 0
3232 token : ${{ secrets.CLOUD_JAVA_BOT_TOKEN }}
Original file line number Diff line number Diff line change @@ -318,7 +318,8 @@ void stop() {
318318 case WAIT_FOR_PROCESSING :
319319 logger .log (
320320 Level .FINE ,
321- "WAIT_FOR_PROCESSING shutdown mode: Waiting for outstanding messages to complete processing." );
321+ "WAIT_FOR_PROCESSING shutdown mode: Waiting for outstanding messages to complete"
322+ + " processing." );
322323 java .time .Duration timeout = subscriberShutdownSettings .getTimeout ();
323324 if (timeout .isNegative ()) {
324325 // Indefinite wait use existing blocking wait
@@ -330,7 +331,8 @@ void stop() {
330331 if (!completedWait ) {
331332 logger .log (
332333 Level .WARNING ,
333- "Grace period expired for WAIT_FOR_PROCESSING shutdown. Nacking remaining messages." );
334+ "Grace period expired for WAIT_FOR_PROCESSING shutdown. Nacking remaining"
335+ + " messages." );
334336 // Switch to NACK_IMMEDIATELY behavior for remaining messages
335337 nackAllOutstandingMessages ();
336338 }
Original file line number Diff line number Diff line change @@ -796,7 +796,8 @@ public Builder setOpenTelemetry(OpenTelemetry openTelemetry) {
796796 * SubscriberShutdownSettings#newBuilder() default settings}.
797797 */
798798 @ BetaApi (
799- "The surface for SubscriberShutdownSettings is not stable yet and may be changed in the future." )
799+ "The surface for SubscriberShutdownSettings is not stable yet and may be changed in the"
800+ + " future." )
800801 public Builder setSubscriberShutdownSettings (
801802 SubscriberShutdownSettings subscriberShutdownSettings ) {
802803 this .subscriberShutdownSettings = Preconditions .checkNotNull (subscriberShutdownSettings );
You can’t perform that action at this time.
0 commit comments