Merge pull request #33 from momentohq/topics-resilience

chore: add a keep alive timeout for the topics channel
momentohq · Jan 3, 2024 · 235adc3 · 235adc3
2 parents 74e46c4 + 05c41c2
commit 235adc3
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/androidMain/kotlin/software/momento/kotlin/sdk/internal/TopicGrpcStubsManager.kt b/src/androidMain/kotlin/software/momento/kotlin/sdk/internal/TopicGrpcStubsManager.kt
@@ -55,6 +55,9 @@ internal class TopicGrpcStubsManager(credentialProvider: CredentialProvider) : C
             val channelBuilder = ManagedChannelBuilder.forAddress(credentialProvider.cacheEndpoint, 443)
             channelBuilder.useTransportSecurity()
             channelBuilder.disableRetry()
+            channelBuilder.keepAliveTime(10, TimeUnit.SECONDS)
+            channelBuilder.keepAliveTimeout(5, TimeUnit.SECONDS)
+            channelBuilder.keepAliveWithoutCalls(true)
             val clientInterceptors: MutableList<ClientInterceptor> = ArrayList()
             clientInterceptors.add(UserHeaderInterceptor(credentialProvider.apiKey))
             channelBuilder.intercept(clientInterceptors)

diff --git a/src/jvmMain/kotlin/software/momento/kotlin/sdk/internal/TopicGrpcStubsManager.kt b/src/jvmMain/kotlin/software/momento/kotlin/sdk/internal/TopicGrpcStubsManager.kt
@@ -55,6 +55,9 @@ internal class TopicGrpcStubsManager(credentialProvider: CredentialProvider) : C
             val channelBuilder = ManagedChannelBuilder.forAddress(credentialProvider.cacheEndpoint, 443)
             channelBuilder.useTransportSecurity()
             channelBuilder.disableRetry()
+            channelBuilder.keepAliveTime(10, TimeUnit.SECONDS)
+            channelBuilder.keepAliveTimeout(5, TimeUnit.SECONDS)
+            channelBuilder.keepAliveWithoutCalls(true)
             val clientInterceptors: MutableList<ClientInterceptor> = ArrayList()
             clientInterceptors.add(UserHeaderInterceptor(credentialProvider.apiKey))
             channelBuilder.intercept(clientInterceptors)