Skip to content

Commit ca99c2a

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 parent 4e59581 commit ca99c2a

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
private final boolean maxDurationPerAckExtensionDefaultUsed;
145145
private final java.time.Duration minDurationPerAckExtension;
146146
private final boolean minDurationPerAckExtensionDefaultUsed;
147-
private final long protocolVersion = 1L;
147+
private final long protocolVersion = 0L;
148148

149149
// The ExecutorProvider used to generate executors for processing messages.
150150
private final ExecutorProvider executorProvider;

0 commit comments

Comments
 (0)