Skip to content
This repository was archived by the owner on May 4, 2019. It is now read-only.

Commit c18ded1

Browse files
committed
make sure keep alive is enabled
1 parent d99ff12 commit c18ded1

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

proteus-client/src/main/java/io/netifi/proteus/rsocket/WeightedReconnectingRSocket.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -190,22 +190,17 @@ private RSocketFactory.ClientRSocketFactory getClientFactory(Payload setupPayloa
190190
if (keepalive) {
191191
connect =
192192
connect
193-
.keepAlive()
194193
.keepAliveTickPeriod(Duration.ofSeconds(tickPeriodSeconds))
195194
.keepAliveAckTimeout(Duration.ofSeconds(ackTimeoutSeconds))
196195
.keepAliveMissedAcks(missedAcks);
197196
} else {
198197
connect
199-
.keepAlive()
200198
.keepAliveAckTimeout(Duration.ofSeconds(0))
201199
.keepAliveAckTimeout(Duration.ofSeconds(0))
202200
.keepAliveMissedAcks(missedAcks);
203201
}
204202

205-
return connect
206-
.setupPayload(setupPayload)
207-
.keepAliveAckTimeout(Duration.ofSeconds(0))
208-
.keepAliveTickPeriod(Duration.ofSeconds(0));
203+
return connect.setupPayload(setupPayload);
209204
}
210205

211206
void connect() {

0 commit comments

Comments
 (0)