From d24a338e80bf79f304037bd3a391b2958ac6a061 Mon Sep 17 00:00:00 2001 From: zeaslity Date: Thu, 30 Mar 2023 15:10:27 +0800 Subject: [PATCH] =?UTF-8?q?[agent-go]=20=E4=BC=98=E5=8C=96=E4=BB=A3?= =?UTF-8?q?=E7=A0=81=EF=BC=8C=E5=AE=8C=E6=88=90=E8=BF=9E=E9=80=9A=E6=80=A7?= =?UTF-8?q?=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- agent-go/g/global.go | 2 +- agent-go/octopus-agent-dev.yaml | 4 +- agent-go/rabbitmq/OMsgConnector.go | 45 +++++----- agent-go/register/AgentInitialization.go | 85 ++++++++---------- .../nacos_config_export_20230330143045.zip | Bin 0 -> 11759 bytes .../octopus/run-enviroment-compose.yaml | 2 - 6 files changed, 65 insertions(+), 73 deletions(-) create mode 100644 agent-go/tmp/nacos_config_export_20230330143045.zip diff --git a/agent-go/g/global.go b/agent-go/g/global.go index 4cf4360..c5f7247 100644 --- a/agent-go/g/global.go +++ b/agent-go/g/global.go @@ -20,7 +20,7 @@ const ( InitOmType = "INIT" ) -var pool, _ = ants.NewPool(100, ants.WithNonblocking(true), ants.WithLogger(logger2.Log)) +var pool, _ = ants.NewPool(100, ants.WithNonblocking(false), ants.WithLogger(logger2.Log), ants.WithMaxBlockingTasks(30), ants.WithDisablePurge(true)) var G = NewGlobal( pool, diff --git a/agent-go/octopus-agent-dev.yaml b/agent-go/octopus-agent-dev.yaml index 87c7d61..ac474f7 100644 --- a/agent-go/octopus-agent-dev.yaml +++ b/agent-go/octopus-agent-dev.yaml @@ -10,8 +10,8 @@ spring: config-retry-time: 3000 file-extension: yaml max-retry: 3 - server-addr: "150.230.198.103:21060" -# server-addr: "42.192.52.227:21060" + # server-addr: "150.230.198.103:21060" + server-addr: "42.192.52.227:21060" timeout: 5000 config-long-poll-timeout: 5000 extension-configs: diff --git a/agent-go/rabbitmq/OMsgConnector.go b/agent-go/rabbitmq/OMsgConnector.go index ec016ff..2be7108 100644 --- a/agent-go/rabbitmq/OMsgConnector.go +++ b/agent-go/rabbitmq/OMsgConnector.go @@ -28,26 +28,6 @@ func BuildOMsgRuntimeConnectorQueue(agentTopicName string) { } octopusMsgQueue.Connect() - deliveries := octopusMsgQueue.Read(true) - - // 死循环，处理Octopus Message - P.Submit( - func() { - for delivery := range deliveries { - - var om *OctopusMessage - err := json.Unmarshal(delivery.Body, &om) - if err != nil { - log.Error(fmt.Sprintf("octopus message convert to json is wrong! msg is => %s", delivery.Body)) - // 保存到某处 - continue - } - - // 策略模式 处理消息 - om.Handle() - } - }) - // 建立 业务消息 返回队列 // 统一为 OctopusToServer @@ -67,6 +47,29 @@ func BuildOMsgRuntimeConnectorQueue(agentTopicName string) { // 开启运行时消息返回队列 OctopusToServerQueue.Connect() - log.InfoF("Octopus Message Replay Queue is established ! => %v", OctopusToServerQueue) + log.InfoF("Octopus Message Business Runtime Queue is established ! => %v", OctopusToServerQueue) + + deliveries := octopusMsgQueue.Read(true) + forever := make(chan bool) + P.Submit( + func() { + // 死循环，处理Octopus Message + for delivery := range deliveries { + + var om *OctopusMessage + err := json.Unmarshal(delivery.Body, &om) + if err != nil { + log.Error(fmt.Sprintf("octopus message convert to json is wrong! msg is => %s", delivery.Body)) + // 保存到某处 + continue + } + + // 策略模式 处理消息 + om.Handle() + } + }) + + // wait forever + <-forever } diff --git a/agent-go/register/AgentInitialization.go b/agent-go/register/AgentInitialization.go index fac6152..436537a 100644 --- a/agent-go/register/AgentInitialization.go +++ b/agent-go/register/AgentInitialization.go @@ -57,18 +57,18 @@ func INIT() *AgentServerInfo { if err != nil { log.Error(fmt.Sprintf("octopus message convert to json is wrong! msg is => %v", octopusMsg)) } - log.Debug(fmt.Sprintf("Prepare to send init message to server! ==> %s", string(msgBytes))) // 发送OM至MQ中 P.Submit( func() { for g.G.AgentHasRegister == false { + log.Debug(fmt.Sprintf("Send init message to server! ==> %s", string(msgBytes))) + //如果agent存活 而Server不存活 那么需要持续不断的向Server中发送消息 initToServerQueue.Send( msgBytes, ) - // 休眠 time.Sleep(10 * time.Minute) @@ -96,66 +96,57 @@ func handleInitMsgFromServer(initFromServerQueue *rabbitmq.RabbitQueue, initToSe initOctopusMessageDeliveries := initFromServerQueue.Read(false) - forever := make(chan bool) + // 同步很多抢占注册的情况 + for delivery := range initOctopusMessageDeliveries { - // use the ant goroutine pool - P.Submit( - func() { + log.Debug(fmt.Sprintf("message received from server is %s", string(delivery.Body))) - // 同步很多抢占注册的情况 - for delivery := range initOctopusMessageDeliveries { + var initOctopusMsg *rabbitmq.OctopusMessage + err := json.Unmarshal(delivery.Body, &initOctopusMsg) + if err != nil { + log.Error(fmt.Sprintf("parse init message from server wroong, message is => %s ", + string(delivery.Body))) + } - log.Debug(fmt.Sprintf("message received from server is %s", string(delivery.Body))) + var serverInfo AgentServerInfo - var initOctopusMsg *rabbitmq.OctopusMessage - err := json.Unmarshal(delivery.Body, &initOctopusMsg) - if err != nil { - log.Error(fmt.Sprintf("parse init message from server wroong, message is => %s ", - string(delivery.Body))) - } + s, _ := initOctopusMsg.Content.(string) + cc := json.Unmarshal([]byte(s), &serverInfo) + if cc != nil { + log.Error(fmt.Sprintf("parse init message from server wroong, message is => %v ", cc)) + } + serverName := serverInfo.ServerName - var serverInfo AgentServerInfo + // 处理OM信息 + if initOctopusMsg != nil && initOctopusMsg.Type == g.InitOmType && serverName == agentServerInfo.ServerName { + // 是本机的注册回复信息 + log.InfoF("OctopusMessage INIT from server is this agent !") - s, _ := initOctopusMsg.Content.(string) - cc := json.Unmarshal([]byte(s), &serverInfo) - if cc != nil { - log.Error(fmt.Sprintf("parse init message from server wroong, message is => %v ", cc)) - } - serverName := serverInfo.ServerName + // 手动确认信息 + delivery.Ack(false) - // 处理OM信息 - if initOctopusMsg != nil && initOctopusMsg.Type == g.InitOmType && serverName == agentServerInfo.ServerName { - // 是本机的注册回复信息 + // 修改系统参数 + g.G.AgentHasRegister = true - // 建立 运行时 RabbitMQ连接 - agentTopicName := initOctopusMsg.Result.(string) - rabbitmq.BuildOMsgRuntimeConnectorQueue(agentTopicName) + // 建立 运行时 RabbitMQ连接 + agentTopicName := initOctopusMsg.Result.(string) + rabbitmq.BuildOMsgRuntimeConnectorQueue(agentTopicName) - // 手动确认信息 - delivery.Ack(false) + // 手动关闭 注册队列的连接 + shutdownRegisterQueueConnection(initFromServerQueue, initToServerQueue) + return + } - // 手动关闭 注册队列的连接 - shutdownRegisterQueueConnection(initFromServerQueue, initToServerQueue) - - return - } - - // 不是自身的 注册回复信息 -- 拒绝 - log.Warn(fmt.Sprintf("OctopusMessage INIT from server not this agent ! => %v, ==>%s", initOctopusMsg, delivery.Body)) - delivery.Nack(false, true) - } - - }, - ) - - // wait forever - <-forever + // 不是自身的 注册回复信息 -- 拒绝 + log.Warn(fmt.Sprintf("OctopusMessage INIT from server not this agent ! => %v, ==>%s", initOctopusMsg, delivery.Body)) + delivery.Nack(false, true) + } } // shutdownRegisterQueueConnection 关闭初始化连接的两个队列 func shutdownRegisterQueueConnection(initFromServerQueue *rabbitmq.RabbitQueue, initToServerQueue *rabbitmq.RabbitQueue) { - + log.InfoF("Shutdown register queue connection !") } func parseAgentServerInfo() *AgentServerInfo { diff --git a/agent-go/tmp/nacos_config_export_20230330143045.zip b/agent-go/tmp/nacos_config_export_20230330143045.zip new file mode 100644 index 0000000000000000000000000000000000000000..2c33e55b25437245eaac9850f1f83aa9d5608945 GIT binary patch literal 11759 zcmeI2WmH^Qv-feg;1V=6P6u~)2{a){a3>Jl-QC@T1Shx!cMtAPaCaxz3z?Z`GV`vP z`+U3~?(WrVojz-I^{(o(Yu9i8OHLXR3KI+t4i0R}#$5^QmqGM&ZEB&XWBS@c&(^}y z&W2v+gMqm%{m*+qCml0WnXopLb`m82Be&q@RtWKq!P|*^oKjPhUUVoZwx0QhV2bnO zyqh0+TA8)-3ZA&G0|=<{Qeb6EiL-c{@k$kqB+bTh9HV8pVEl%}@tv?{y&H29Dq9Fn zws4PF~5?`q|E3*u9u1LT*slh_YMVI%+=6waqe?C9`%1laq#p z+w*>K2z;9H!qZ#sAAQ34k576QW@Z-Vzc^E@*k+C?j@EQbD|L-d7nWpD$)*AiNFezf zDFSh*bYyy99+GzWxxsmQC`cHEM6}hb7mBnsIxA9`%o|Op`vt#VX%pom1S>P|(pO=q zs8yeXk`kv`;GYwL?|CWE-FuSsR9hOmZDgva?FoTcbRkRD^*&h+>$@#CYVY2Qkm;sA_)uqhEAc3 zL5#Ia&9}n=l$ zuWLigg?{~w^VgeQqpQoM??)&^Jp8T~vE?W=X~d>SZ?w#1h`%S@TYEfS?qw}&N+6_NK zKYT%!MQ0qq5w9`{nle$=GOsVwW@7RyEnyem>SR!d;dbbi-5_9wY6d$LU%?VIJY6tq zy)Y%WHOd;}G?B?hOmMofYixmAa9-%NgXNgG_ebo7B08#VsiVv`p)z+qf5Dejjh{nN zYhI#Q_-OsUtoxm$4J11sSY!7}%<^~N#ux}X!(JusDTXqNM+Gc{LwLdjj$;q%pw=zb zO(+}I&yyRdnJiF<`0H5>!($@28V|(Qm43Rjm1V> zpVaVNM)r@Kg`exy^dhy!Ez#TT^R3h3CzGMWbJVy{7o-hj% zK<61uZKF{=(!1csYwxHx+#zeV%b%@AmUTvCp}RI6751M6QF=%Av8#kdk~^KfaIZ#T3yrM+oSxPn;` zeNmNPMOBrhPk2NG2K!ggZUjr8Vq!NHfmUWpa0YD(lr3>)t3O({-$T-jS?M*R%l+t> zebdYanP~a&tyS8UTiR8a_yUDhKc~O3-1KW^8dq!1U8j?$Wb;)b$xGb-1P+<5`4bOw zsE_F?D;f-~{cbRjARpt{+R#pNGFvuD5Sa~L?`A-b(u@O8Pq*!zPmBJ-HXBpn4T85J z96%5g0Utd`6CLYwWS1jU15`#G&V|l?@2-)c0w}F8eN%jBEaZ|zOPPyJo~zsTOzKQN zM{Z5jY8gX!MWVCTm>P(sK6niZR3tkUrNdCc)>rJP$WDM$0%$6S;LDeXPDHm8Fmd|6 zFC9jTqnKMNQahs%4?BA`XEc&naUXB4ZlpzowB&&ixYD8-SK>nsn_g#mY2| z7c1xfgXw69g}#81Pa|mx7{=0lzuJ{sbh>qqWR)crr1v$vJyg}EWFgw^ZBh-Y4hjz& zB2Qp46`&Kbu}wNN6FxIgIvE&3vl<2gGtfx0lNpMxYt+phBXy4t)v6T0Kw^5mO~Q50`de$ z(J17}W!6xDuQWuJvJf=cnb2q?1G-eB5>IFyAM!!^rzAo=^xQ4g>KMT7d8e`P1jNy| z&e@^69aVQ{qw`=E_mx%m0r9>Yk087;Oi}8DGyIYr1-%Kb(^MzrC!a?p7t_9hNt?@z*)EDDHp4OWMg$a0JO7O4U8O4%2qsMN{*(+$c z^C!uG%FKJctaYW)>7+(-0Asn;PjmJ+UuAl#AX8W`9A6zV*@VviXsW3^pT69bvfVPi zz7srm=2boP2PtLcuyae7@|!Qrsd$t%U5WrZ(<2BFT}joi&9@%bA_&+kUs{Px1?(Du zy*!iJuT9{SdD-*>Fqqu*aBltD>UFzQDRT?du1x#ZfwjI8 zAK184`rWH&K84>uLg_1!dkTer0L$KG7=QbbN66vQ-c_3EqjTZoR|gta-^H*90#v>F zicZEpI@<|0@Vn--Q2RuPDay3rA?Qx%4Q2lxe^^R9zJ$to{8O3tB1(~Wvt0{iy-ZQ! z%V;ZHUm)CLtTU*9abS5b)*aP-yj>j2rM0fO%TO+6S&-*Nl)w_OP-al)Rtcl0(7?tV+t%fIR_4`4PqT`9Kn^AJ zV(bm0r!v~;hM1i%?2gXA(~Gbxdx>%IbnUCRG+nrx-FE0YX5rBDBC{t{TqqgHG=RU7 zU8D){^u%8o@FhbrRm2q^I z=)Iso4%Vs2BZB)etdJgwGX+2sBgBn5o@F2X#-xs;`RMXt=jP$~_%P(*$M``t>PRSg zFYKY&>a_~HC0$7^Je_B-Vx++${Y_iQ@lvH_7QvFs=+WYwbV}kl$12GnS?ito=bl7U z|9CBbeup*bn8kSk_X815R2d^Qc8^t&2dL?a;)U|;*Or~#+PYtxPQAbqz&a-T+;6LplCd@W}D_5WH{47>!W$9_8=_^*{<*0gJ)0E4XF)%PJ zuYT(Tfrba9Vd1y3<8wAWaS;$U3M7>flAMfh)YWhL05{M%T_h)+=M#tIkvWt(pYI~JC^Pbxq=k#(K z(4see1zlauL0F_obp;PO0?J8vo*Ti^=+Y$d-U7OU;GqQ>8HLNRwpM=bM1dmc7sW^@ z=cB{Lbie^Y^e`%^qKQ&4bP3%DwAY;8>P4s*>A;zLiC}N}cT6D{Ap+zTM!NFyhCvn? z?k^If)Ow+RR>VeB^27&EAyEeZx1eGC9<<-<;Xk5Ptn}T2Kore=Sc~zC7Rgv0-=kES zLK~t)AO!k>OBG+lT8=}*;Zj=6v4WxmIlZyBh-85fi6VrkcXWKdh@{*j-uEu|Z!N9+ z_hrM>Q6avsXqS@ej^=L+?Jw_2R&~o6A(t6}10G`)Y3WxSO~E9Fh*F~ zz}%oW@99l#+E^3Xqj?pAYmjuYzr3&Pt9Ib_I+W02Z!L)n-jFIVYGKx@l8&1hj|=A6 zkasJ2Sqe!Ur%l9`L5+hk1U$P36sQLEl{7mLx@=GBYDLfzGE7Usm2|Tu+~Pxj@x^c5 z(wy!x6;%^1R_d1agkadhuEKLDhn8NjqlWTRdSf&~=sUcszU&;F;xeY!k3EjxR6-H= zjT04NioEudEuQilRCOZ--c2C^eD5tSu)zi7{AsBi`5^)mS-cja&t+Zr@J)pmy2YAR zg*KuMpOoiI1^|)txhgR?+4ja?CZH`BJTWEg=tq=$<9EVG@msw=<`_+X>AI1MGQ!vU z(tm%6>ERUI!qlaex>`D@pF`cc+@`hC?Xa?R*0#bYGVjpdq~)(w95752kn&xmrh&RyCaF859>_qqs7(`wW! zFU9~yD3%%In!3T0(IsgBzP0@o^GAF{Iy*aJc70nNkM zjNE|pm~M%8QpkchMn)B_lgkprF%XusI}A}noHi9WOwy2i*&DY`9^gi7W7#rdu@RYZ zR$lScpyhG2+|OP2p{w?uf+$-3eoz3?T55~V!p8~~xrs&pP3)38#AApg$~JzfH42Oj z8=ncste10A&KAjjL8-lKkW6=4N$agWb)oRxv)NgR9&K-g<%B{u{pGA$z(_mPb}T(y zs=&YH8z$4`rR2VF&yf%2SC(G~#n^inJsiVp1X&)aQjly2j-ZT7sP4)}o86ht1=jIN zl>@8fyN|8DJjlRHI{W*X-zc=!_SYIokLyx9sUvEylfWIm8QGkpHR!d&1!iFwC25lM z(WlQA*^{i=7?=xbF%w?jlwp3yr<@bq+#T8`nx@r2u!+SiXuD&{!!<0OV<32JLadyn z^)i$iCkXA&Z;V^dcCmeJ^MOUV&XQ}hYn}Kx`({^5|A2!61EYcew?snldm=G#G|;oN zwXmi)v@_SUHMTJSE&VIUr=n!0-ww@zrL(D9 zfJr>_D8`uG;o(hZwv6^j*h8$OY0c?}wtE(%=#fgF9{O|Xuk3+%Z=x=vM?NXsM7e3r zMW<+oO>9qeRejm9f%IA>8k{egMJTd|7yGga-|r*dkGYUBwIICM2XmGlevr^WX3=bh2J#rdqw7DU{(!bg*P=Fnq^3Z!6LE9sP7Mp z7@E-H_wOb~)`*LOKNbq~RBKcv?|!q zXxCG*Xvl*A5clx+?4^A4BT~05&O_0vow1ocOFc`i+ zxFh|+{dhT|!(z!B{s~~=9Hnp!VB(S1Uf{nM;#B#AVX1#-SU78n|1d10p5L1%hMjq0 z*xk%*T2ZoHi50~+j&GSeqp5-#{mC;E$VJzg2_m!;z$C7|@Ocrcq^<%k?zS!v+t&fk zlSCN1Qaxf)J@1V)Ei?;{Sp}oTnBRqxh>Qm?LpLi>NqUn>-7(^yG#Ocr%d6AWC!eH@ zPTd;L3TW5TVx*|i?f?mBg_0{{6aE2yMcPzM6P#t z<3Ww>n$%fH`Q>?L+b|tj!RCMmZrBsl{%D@#I7GkHH|bJLId~L}NlX>%z`=sY>GTHb zK}-3T8)-v_I7>!;2Ik96uqcX(@cC@I_ID~Pe2Ll^djDbrrx|UbD_7BUfKCCs$|NQX zuf?*Oy0G2gkv+qBg34-O>h?Hes)DvgUrSzTpV<*2Vh{=RicAU~K2sY`RB}{AvK=6k z0KkHWi2#qtz_yd@_IHGN%i!>Es()c)^U=P*+i)v3$mERHFP=>U&t$U)IHZmgXpj68 zYf)cS zsm*;CR=(XUPK2xu7M-|V0S=^uwoU5#KhpaI3YkgW(4`%g8yv<9?s|W4dpn;wi2bV$!;*tmB z>-#JR7j|aia`7oxTNcl6h*Cw4>wI=Eo7_J+5Au1q+O6Z7gRRIdiWQT0!{lJ^B@x0^ zIj&PXpOCvY;n~$>a;vTEraT-H9&^n+lDgKyJ4o(wG%KK&`Vb6v96h{PY??me#k)g3 zOk1KXAlW}`ns-48y6@r}>V;n=zCNy%vRVDYq zI;-V2x8+R3lhK=>nHWTDhskCR1}=eercH?-Pdgl#Yr@sk)c_g?@!mdjcdqiLWs;)+-g75 zIvQk>gu)5V7ez$dBVo2&IcgZF^-9j7`%Gg!=HqQ3xaqey86_%q%`6wMghP~M2DYJ? zgm62^2GMA}=z$lXx-K7C5O+ua^HgV63?53S(4 z0v-Xw&Eah9%eBYzk4V#6pIA_jn)i?R2u&XmX5WOmX2i(6IZ>()DNyn_LHp}oU8n%Qr8-q`Fq;us=fo+>lMf2+(0pDMH8gq(k< z&Eg^$%{v&7L>;> zgrEeQKJG!Ekal9KnnRi{ltz)u$>1cGo9>6SAsB>8zC$8$jcL{%?%k`%TnU2xuAzIh ziRlO$g~&?zDI(7MxaEMWmb+YT++(_WLD}uus^ZxL^HU+~X#;Z$c#rQEJ+2Q!PQ03Y z#Su)U)_5L251(^!nGC0%+#ml}27W#`&^NIE+rh!po!?Zh@ZVJ~9#JjrHphj*2Ad@3 z<8OulawJ?#1B)ZvapkK4+j4K(8!xufhD^?~I0G>D0o z!TN4HV4rF*{6~Upm6OTFB?FjNI766P6C@U0m$j-}yyK%;mzP19A|&6yP!8 zrBpM~0fP4*TybuxA0aBQI{5NLP|(Bo9Y1U~TeKw2s=yLec;#H-|3G|OC@F+(u#HehY zEDKDPP0pyZ`&mpXJS%wl0n-4>#>n#zD)ggj64SQbM#$Q2rp4;T!||ol-$cf6F*No| zWl!ec-BnXR%u+x6c%zw!jzsi;RqTOt(2VmPO|Dm=5Aj0&d3AP zG*}ADNFvst;3 zb-!}5)^@hIeJJ^Oy#0fUZ%0%73^>`s<-j;_d}38qNodiGZ%*_nwdnlOT}BE9mLGjd zduw**@a>&7<&r9)d&`UBMlNm@`U;gv_%hXIjlr&_hr#9NLK4?{+<;4+EYLYlc`hs%bo^1;TdrJM7nbpjy>H*~pcZJ+l17REeLjcznYwIGs1Sq#R(u`(=e zfFn$6@R0beEESHC?-t-0>6T6EA~Un0YSst!FSOVYgX`x<7P>b)z%@zE$gcxb7P7&( z*d@Z)$42DGT8a=bxIeGCJ<+`s!m=K{o_Be&DcafVL}NJgDx*W#xN}4_rpCCi%NlV4 z5>dNxeZNLy{AJ~jaqD&f;RhBo%HBQH^btQecJp<3azdyBhOk)aMcGM;VZ*TZ+gV6^ z>a-h3#2;o`0Hkpr-f#O4qbJ(p;m{ka(!BzG1P^@))s_lBC*)#)SI?fxPyF7A8kg>1JK9*@R6$Xe8n67oD&w2U7dHNt&&wHujtZgFU6 zv4OR3KM1%_Z9!^z+-mFKM}E9Ud7~a&CffS0o{G6lA2*`b3lJN_+QHFFp$VxIshd}_ zUE#&$Me;#j>PzlkEZ&4R2D4Hxl--!WMrMB|P^w;@JTn|qv&$EURhTX)y4OU4%vn-i zgs<`hF1PbF^ZDPI{^|=a#Y9|qSZsLtNaIqY(u#>Ud6;1?u3%s;>IVeZ0=Z}?(b#J} zmQ~o%<=h-O!vC7-jRsRvn1G;m!U<4LGS*P+9I-So`*Sk69T8R4@ga2W0hJIa|PeWRaE zh{d`^N^8|)?iddYlo#@*!WDWe&+<0fQgYltQq;Rmuk}^Fs77=-X__GBKxzw*%KgHp zWQ{Kwvz!L2b9Yjob7YjelW)pHm~kL8HG~Cw1jX*x0_mnlHMWF3={`E}6duq@6CTlJ zaHY(pcE6+R0|>s=7iNV*UL$JXaAGx^T2P&k0o-Lct4W#OY?0KVl@0l^`SSuvK(dbQ4vGK8v1b{ z`2?F>8LpC_RDUma_eOFJLIt1CPJ@4gTtL;TK+}+=Mha@jVLV&1NO#WdK+ONCv4~!% zE?Gr?|T(eP|Xau@^b<010&Blpbr&_g~%Extha znJ~8cmGNSu`vc2+*u=$-MOdGMJSO7DrtfN4*OnK<9Tvnb-y7m?0(mR=GHf98n=?9t z#Sh>0jHXZ)Oz)pHOpAxFV56Z-noUUQn%0&)i_{SGL{7n)e8}HT#TJXV50z?vd~I>T zX+*hv#OIsyy(PDMsYMqw-8P7`!u}Y1xOjAxhVlS@1v(m6K(oJEI^qrOkK+sv84waP z!|>)WPmd$~;d2qRRoM^zxpnwk=XvMM%U9$zTJZ%fi~C2-2S={s-(8|Z<~`Zyw|zPz z2;Vo)3QW8v7S>0`K#y-*yGa_B4W#n2S+0s1`?NR}Y0*AX?!7)2rqW8*FGA!ckU=g zLISe|2<)~{FkP|5hI?Y=EHyO&(wVzhJa@OP<;Bb8yy|1a*Qy@ahoyP4Bv4aT1PprW zsvE01O0Pa8DTG0)U>SmM-EgtMJ&D}3Ui|RiW*Z-BbJmDTfDPk2yS+pb*Nc1GL-sRj zJ~fK9KMn*f(hWKe1|J%#eb}FVjTkcg6}-(g*B)Umd9KDQ1FrxLgfOHCvfn8u_SY_sX2OZZO9|(p3Cq zwu%UU$vs>QvS--z%GKia$oi=fNsE2SrvP#mxWRPp1pc0CQ(E@ub?C1%9EpiQ&6`+o z0GjTXRl=0}pMpzd=IhFUC#=W&SFC@k*1&*f2DUmtCo|LjK9KCdXg>(p_nL}+O6Cn{ zkalzsJZMspVsmpFfQ>nmDRFAOk+DtnQw49&fhOzkk26ybHH4Le%0niZEWj%0%K_Yo z)*I(I^#PJ@oUY@tIAIHS7d`L`@nOf*`LGg zN!I%7g#N#_v%eerRaSpKIQVmvKXoVkbN|8L?fj~$J)`-bWAo{6f41|xUw;S?e>d=} zs_`to{W)Hv{bt}FO7*`R`t=m)uZE7%|LW22!TF~d{d(H+eCYJ&=)?OX&j00{em&Co zYm|4NKK@$9{nnKHM-}&X-+pDAzeaiF$<=2&e>)EOyMcd>GAhY$2L4NreqGdmjq(WD rUp@Lg%KzljuS@Sa2mCoQsDH@_a?;RGDFh4*`RNt^M0dh8&!7Gu<_sG@ literal 0 HcmV?d00001 diff --git a/source/src/main/java/io/wdd/source/octopus/run-enviroment-compose.yaml b/source/src/main/java/io/wdd/source/octopus/run-enviroment-compose.yaml index e1f33b9..107a94e 100644 --- a/source/src/main/java/io/wdd/source/octopus/run-enviroment-compose.yaml +++ b/source/src/main/java/io/wdd/source/octopus/run-enviroment-compose.yaml @@ -78,8 +78,6 @@ services: - MYSQL_SERVICE_PASSWORD=Superwmm.23 depends_on: - mysql - volumes: - - 'rabbitmq_data:/bitnami/rabbitmq/mnesia' # redis-replica: # image: redis-image