From 7f184bae50f6fa9d02469a9a1ac287edfc7555f6 Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Thu, 4 Jun 2020 17:25:42 +0800 Subject: [PATCH] --- src/org/redkale/cluster/ClusterAgent.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/org/redkale/cluster/ClusterAgent.java b/src/org/redkale/cluster/ClusterAgent.java index 3b06d6162..ae6b4e223 100644 --- a/src/org/redkale/cluster/ClusterAgent.java +++ b/src/org/redkale/cluster/ClusterAgent.java @@ -8,7 +8,7 @@ package org.redkale.cluster; import java.lang.ref.WeakReference; import java.net.InetSocketAddress; import java.util.*; -import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.*; import java.util.logging.Logger; import org.redkale.boot.NodeServer; import org.redkale.convert.json.JsonConvert; @@ -238,6 +238,8 @@ public abstract class ClusterAgent { public InetSocketAddress address; + public ScheduledFuture checkScheduledFuture; + public ClusterEntry(NodeServer ns, String protocol, Service service) { this.serviceid = generateServiceId(ns, protocol, service); this.servicename = generateServiceName(ns, protocol, service);