|
@@ -30,14 +30,14 @@ public class VertxTcpClient extends AbstractTcpClient {
|
|
volatile PayloadParser payloadParser;
|
|
volatile PayloadParser payloadParser;
|
|
|
|
|
|
@Getter
|
|
@Getter
|
|
- private String id;
|
|
|
|
|
|
+ private final String id;
|
|
|
|
|
|
@Setter
|
|
@Setter
|
|
private long keepAliveTimeoutMs = Duration.ofMinutes(10).toMillis();
|
|
private long keepAliveTimeoutMs = Duration.ofMinutes(10).toMillis();
|
|
|
|
|
|
private volatile long lastKeepAliveTime = System.currentTimeMillis();
|
|
private volatile long lastKeepAliveTime = System.currentTimeMillis();
|
|
|
|
|
|
- private List<Runnable> disconnectListener = new CopyOnWriteArrayList<>();
|
|
|
|
|
|
+ private final List<Runnable> disconnectListener = new CopyOnWriteArrayList<>();
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public void keepAlive() {
|
|
public void keepAlive() {
|