Merge branch 'dev' of http://192.168.2.240:7070/r/kidgrow-microservices-pla...

zhaoxiaohao

2020-07-28 9e1ba007e71d20511e1d8403edf9061eb6cb6ad2

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
Êþº¾3ß    1d
2e
bf
gh
gijkl
gmnopq
eorstutvw    xy
xz
{
|}
~
€
e
‚ƒ„
…†
‡
ˆ‰Š
‹Œ
jŽ
b‘’“    ”•
”–—˜’™š›œ
this$0
8Lcom/xxl/job/admin/core/thread/JobRegistryMonitorHelper;
<init>
;(Lcom/xxl/job/admin/core/thread/JobRegistryMonitorHelper;)V
Code
LineNumberTable
LocalVariableTable
this
InnerClasses
:Lcom/xxl/job/admin/core/thread/JobRegistryMonitorHelper$1;
run
()V
appName
Ljava/lang/String;
registryList
Ljava/util/List;
item
-Lcom/xxl/job/admin/core/model/XxlJobRegistry;
addressListStr
group
*Lcom/xxl/job/admin/core/model/XxlJobGroup;
 appAddressMap
Ljava/util/HashMap;
list
    groupList

e
Ljava/lang/Exception;
 Ljava/lang/InterruptedException;
LocalVariableTypeTable
$Ljava/util/List<Ljava/lang/String;>;
KLjava/util/HashMap<Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;>;
?Ljava/util/List<Lcom/xxl/job/admin/core/model/XxlJobRegistry;>;
<Ljava/util/List<Lcom/xxl/job/admin/core/model/XxlJobGroup;>;
 StackMapTableš€qwž†—

SourceFile
JobRegistryMonitorHelper.java
EnclosingMethodŸ ?456?¡¢£¤¥¦§¨©ª«¬­®
%com/xxl/job/core/enums/RegistryConfig¯°±
java/util/HashMap²ª³´µ¬¶·
+com/xxl/job/admin/core/model/XxlJobRegistry¸º»¼½¾½ž¿ÀÁ½ÂÃ
java/util/List
java/util/ArrayListĽÅÀÆÀÇÈ
(com/xxl/job/admin/core/model/XxlJobGroupɽÊËÌ

,ÍÎÏÐÑÒÓ
java/lang/ExceptionÔÕ
9>>>>>>>>>>> xxl-job, job registry monitor thread error:{}Ö×ØÙÚÛÜÝ
java/lang/InterruptedException
5>>>>>>>>>>> xxl-job, job registry monitor thread stopÞÑ
8com/xxl/job/admin/core/thread/JobRegistryMonitorHelper$1
java/lang/Object
java/lang/Runnable
java/util/Iterator
java/lang/String
6com/xxl/job/admin/core/thread/JobRegistryMonitorHelper
start

access$000
;(Lcom/xxl/job/admin/core/thread/JobRegistryMonitorHelper;)Z
-com/xxl/job/admin/core/conf/XxlJobAdminConfig
getAdminConfig
1()Lcom/xxl/job/admin/core/conf/XxlJobAdminConfig;
getXxlJobGroupDao
(()Lcom/xxl/job/admin/dao/XxlJobGroupDao;
$com/xxl/job/admin/dao/XxlJobGroupDao
findByAddressType
(I)Ljava/util/List;
isEmpty
()Z
getXxlJobRegistryDao
+()Lcom/xxl/job/admin/dao/XxlJobRegistryDao;
'com/xxl/job/admin/dao/XxlJobRegistryDao

removeDead
(I)I
findAll
iterator
()Ljava/util/Iterator;
hasNext
next
()Ljava/lang/Object;
0com/xxl/job/core/enums/RegistryConfig$RegistType

RegistType
EXECUTOR
2Lcom/xxl/job/core/enums/RegistryConfig$RegistType;
name
()Ljava/lang/String;
getRegistryGroup
equals
(Ljava/lang/Object;)Z
getRegistryKey
get
&(Ljava/lang/Object;)Ljava/lang/Object;
getRegistryValue
contains
add
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;

getAppName
java/util/Collections
sort
(Ljava/util/List;)V
$org/apache/commons/lang3/StringUtils
join
:(Ljava/lang/Iterable;Ljava/lang/String;)Ljava/lang/String;
setAddressList
(Ljava/lang/String;)V
update
-(Lcom/xxl/job/admin/core/model/XxlJobGroup;)I

access$100
()Lorg/slf4j/Logger;
org/slf4j/Logger
error
*(Ljava/lang/String;Ljava/lang/Throwable;)V
java/util/concurrent/TimeUnit
SECONDS
Ljava/util/concurrent/TimeUnit;
sleep
(J)V
info 12
3
4567
8>
*+µ
*·±9
 :
;=
45

>?
8?
p*´
¸š
^¸¶¹L+Æ
+¹
š
¸¶Z¹
W»Y·M¸¶Z¹ N-Æz-¹
:¹
™h¹
À:²¶¶¶™H¶:,¶À:Ç»Y·:¶¹š¶¹W,¶W§ÿ”+¹
:¹
™U¹
À:,¶ ¶À:
:ƹ
š¸!"¸#:¶$¸¶¹%W§ÿ§§L*´
¸š¸'(+¹)²*+¶-§þ·L*´
¸š¸'(+¹)§þž¸'/¹0±

'
*&
@
I
L.9š&#
&'$*2-:.H/L0j1{2‚34’5›8ª9·;À=ÃAáBïCòD

E
F
H
I
$J
'P
*L
+M
5N
@R
IW
LS
MT
WU
bW
eY
oZ:z‚>@A3BCjVDEï5BCò2FAáCGH:íIJHßKC
LC

+MN

MMO

p;=P43BQï5BQ:íIRHßKS
LT
USÿSVWXWYþFZ[WøúüYþC\W[ÿ
VB]K^_`abc<1x    ¹@