16
16
17
17
package com .networknt .consul ;
18
18
19
- import java .util .concurrent .ArrayBlockingQueue ;
20
- import java .util .concurrent .Executors ;
21
- import java .util .concurrent .RejectedExecutionException ;
22
- import java .util .concurrent .ScheduledExecutorService ;
23
- import java .util .concurrent .ThreadPoolExecutor ;
24
- import java .util .concurrent .TimeUnit ;
25
-
26
19
import com .networknt .consul .client .ConsulClient ;
27
20
import com .networknt .utility .ConcurrentHashSet ;
28
21
import org .slf4j .Logger ;
29
22
import org .slf4j .LoggerFactory ;
30
23
24
+ import java .util .concurrent .*;
25
+
31
26
/**
32
27
* consul heart beat manager. passing status service id is registered here,
33
28
* and this class will set passing status for serviceId(in fact it is corresponding checkId of serviceId),
34
29
* then the heart beat process is done.
35
30
*
36
31
* Switcher is used to enable heart beat or disable heart beat.
37
- *
32
+ *
38
33
* @author zhanglei
39
34
*
40
35
*/
@@ -98,7 +93,7 @@ public void run() {
98
93
/**
99
94
* check heart beat switcher status, if switcher is changed, then change lastHeartBeatSwitcherStatus
100
95
* to the latest status.
101
- *
96
+ *
102
97
* @param switcherStatus
103
98
* @return
104
99
*/
@@ -131,7 +126,7 @@ public void close() {
131
126
132
127
/**
133
128
* Add consul serviceId,added serviceId will set passing status to keep sending heart beat.
134
- *
129
+ *
135
130
* @param serviceId service Id
136
131
*/
137
132
public void addHeartbeatServcieId (String serviceId ) {
@@ -140,7 +135,7 @@ public void addHeartbeatServcieId(String serviceId) {
140
135
141
136
/**
142
137
* remove serviceId,corresponding serviceId won't send heart beat
143
- *
138
+ *
144
139
* @param serviceId service Id
145
140
*/
146
141
public void removeHeartbeatServiceId (String serviceId ) {
0 commit comments