Skip to content

Commit 23cffe1

Browse files
author
Deng
committed
disable heatbeat when heartbeat message is null
1 parent f782d55 commit 23cffe1

2 files changed

Lines changed: 18 additions & 0 deletions

File tree

socketclient/src/main/java/com/vilyever/socketclient/SocketClient.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -334,9 +334,15 @@ public long getRemoteNoReplyAliveTimeout() {
334334
*/
335335
private byte[] heartBeatMessage = SocketPacket.DefaultHeartBeatMessage;
336336
public SocketClient setHeartBeatMessage(String heartBeatMessage) {
337+
return setHeartBeatMessageString(heartBeatMessage);
338+
}
339+
public SocketClient setHeartBeatMessageString(String heartBeatMessage) {
337340
return setHeartBeatMessage(heartBeatMessage, getCharsetName());
338341
}
339342
public SocketClient setHeartBeatMessage(String heartBeatMessage, String charsetName) {
343+
return setHeartBeatMessageString(heartBeatMessage, charsetName);
344+
}
345+
public SocketClient setHeartBeatMessageString(String heartBeatMessage, String charsetName) {
340346
if (heartBeatMessage != null) {
341347
return setHeartBeatMessage(heartBeatMessage.getBytes(Charset.forName(charsetName)));
342348
}
@@ -346,6 +352,9 @@ public SocketClient setHeartBeatMessage(String heartBeatMessage, String charsetN
346352
}
347353
}
348354
public SocketClient setHeartBeatMessage(byte[] heartBeatMessage) {
355+
return setHeartBeatMessageBytes(heartBeatMessage);
356+
}
357+
public SocketClient setHeartBeatMessageBytes(byte[] heartBeatMessage) {
349358
this.heartBeatMessage = heartBeatMessage;
350359
return this;
351360
}

socketclient/src/main/java/com/vilyever/socketclient/server/SocketServer.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -204,9 +204,15 @@ public String getCharsetName() {
204204
*/
205205
private byte[] heartBeatMessage = SocketPacket.DefaultHeartBeatMessage;
206206
public SocketServer setHeartBeatMessage(String heartBeatMessage) {
207+
return setHeartBeatMessageString(heartBeatMessage);
208+
}
209+
public SocketServer setHeartBeatMessageString(String heartBeatMessage) {
207210
return setHeartBeatMessage(heartBeatMessage, getCharsetName());
208211
}
209212
public SocketServer setHeartBeatMessage(String heartBeatMessage, String charsetName) {
213+
return setHeartBeatMessageString(heartBeatMessage, charsetName);
214+
}
215+
public SocketServer setHeartBeatMessageString(String heartBeatMessage, String charsetName) {
210216
if (heartBeatMessage != null) {
211217
return setHeartBeatMessage(heartBeatMessage.getBytes(Charset.forName(charsetName)));
212218
}
@@ -216,6 +222,9 @@ public SocketServer setHeartBeatMessage(String heartBeatMessage, String charsetN
216222
}
217223
}
218224
public SocketServer setHeartBeatMessage(byte[] heartBeatMessage) {
225+
return setHeartBeatMessageBytes(heartBeatMessage);
226+
}
227+
public SocketServer setHeartBeatMessageBytes(byte[] heartBeatMessage) {
219228
this.heartBeatMessage = heartBeatMessage;
220229
return this;
221230
}

0 commit comments

Comments
 (0)