Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitca99c2a

Browse files
authored
fix: Lower the Subscriber protocol version to disable the streaming pull keepalive feature (#2652)
* feat: Make v1 the default protocolVersion* fix: Lower the Subscriber protocol version to disable the streaming pull keepalive feature* fix: Downgrade streaming pull keepalive close stream log from WARNING to FINE* fix: Change from FINE to INFO for ping monitor stream closure log
1 parent4e59581 commitca99c2a

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

‎google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -519,7 +519,7 @@ private void startServerMonitor() {
519519
}
520520

521521
logger.log(
522-
Level.WARNING,
522+
Level.INFO,
523523
"No response from server for {0} seconds since last ping. Closing stream.",
524524
elapsedSincePing.getSeconds());
525525

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ public class Subscriber extends AbstractApiService implements SubscriberInterfac
144144
privatefinalbooleanmaxDurationPerAckExtensionDefaultUsed;
145145
privatefinaljava.time.DurationminDurationPerAckExtension;
146146
privatefinalbooleanminDurationPerAckExtensionDefaultUsed;
147-
privatefinallongprotocolVersion =1L;
147+
privatefinallongprotocolVersion =0L;
148148

149149
// The ExecutorProvider used to generate executors for processing messages.
150150
privatefinalExecutorProviderexecutorProvider;

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2026 Movatter.jp