From a4a4b0a9ec4927edfaf50db4a3ada51ed3fb806b Mon Sep 17 00:00:00 2001 From: Igor Date: Tue, 16 Nov 2021 14:44:54 +0100 Subject: [PATCH] modified classes --- src/main/java/com/release11/DAO.java | 15 ++++++--------- src/main/java/com/release11/Main.java | 10 ++++++++-- target/classes/com/release11/DAO.class | Bin 7103 -> 7235 bytes target/classes/com/release11/Main$1.class | Bin 1927 -> 1706 bytes target/classes/com/release11/Main.class | Bin 2377 -> 2496 bytes 5 files changed, 14 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/release11/DAO.java b/src/main/java/com/release11/DAO.java index 8191959..f4165c3 100644 --- a/src/main/java/com/release11/DAO.java +++ b/src/main/java/com/release11/DAO.java @@ -12,10 +12,7 @@ import javax.xml.transform.TransformerFactory; import javax.xml.transform.dom.DOMSource; import javax.xml.transform.stream.StreamResult; import java.io.File; -import java.util.ArrayList; -import java.util.LinkedHashMap; -import java.util.List; -import java.util.Scanner; +import java.util.*; public class DAO { @@ -28,10 +25,10 @@ public class DAO { return xml; } - static int counter=0; - public void hello(){ - counter++; - System.out.println("helloWorld"+counter); + public String getId(HashMap packageMap) throws InterruptedException { + System.out.println(packageMap.get("id")); + Thread.sleep(1000); + return String.valueOf(packageMap.get("id")); } public void splitPackage(LinkedHashMap packageMap) { @@ -117,7 +114,7 @@ public class DAO { String xml = ""; Scanner myReader = new Scanner(file); while (myReader.hasNextLine()) { - xml+=myReader.nextLine()+"\n"; + xml += myReader.nextLine() + "\n"; } return xml; diff --git a/src/main/java/com/release11/Main.java b/src/main/java/com/release11/Main.java index 10907d2..fa9f917 100644 --- a/src/main/java/com/release11/Main.java +++ b/src/main/java/com/release11/Main.java @@ -37,7 +37,10 @@ public class Main { connectionFactory.setPassword("admin"); context.addComponent("activemq", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory)); - //DAO dao = new DAO(); + DAO myFunctions = new DAO(); + + + context.addRoutes(new RouteBuilder() { @@ -46,11 +49,14 @@ public class Main { from("direct:start").to("jdbc:source") .split(body()) + //.bean(myFunctions, "splitMaterial") .to("activemq:queue:material") .to("log:?level=INFO&showBody=true"); from("activemq:queue:material") - .setBody(constant("SELECT * FROM package WHERE material_id = 1" + from("activemq:queue:material"))) + .split(body()) + .bean(myFunctions, "getId") + .setBody(constant("SELECT * FROM package WHERE material_id = 1")) .to("jdbc:source") .to("activemq:queue:materialPackage") .to("log:?level=INFO&showBody=true"); diff --git a/target/classes/com/release11/DAO.class b/target/classes/com/release11/DAO.class index b78168441092095c6496c24948706ee5529f7883..d89e9a924960f727cadfe033b992221e4fc96331 100644 GIT binary patch literal 7235 zcma)B34B~tx&MEYO4F8xCTVFx+OnlLGq=gKvoZHh z+n@p}@X+Uzs_!Y_hAZx9(P`5t;`W}X&!^yy*6qEYit;v|iiq_6&s`>W(qNl5lY7qn z&bOWK`+wg#^YxdGKL+3mxg&xQsx(yVs6nlud7p8>h^LM0czoN~J~LqpYS*Q*Df>!6 zRa^T=1Yy)^i0G(?E@(;QGVy|$HVw;MvnIar>TQCCjFBJC4H&jrNEvBCS6jcsv}mW& z@%~hHznR=(SQ7(AzNfvva=pK(M~P|F(S&9}ot4Utr_Egh{esT6ms`>93UM?avI|_& zQ->&8HO$j79}6l>8=ACiGee7VMH)EYU7E_pw{xA%)uxf@31gukluAZ$HWq1EtYZnz zp~W+{cvg_jxJfoEJUau{W2H?qFQ{(2R&C#E#5G)`V+}5@Aa{L6$p?&d(cHH8 z^!9jO*6<2yS-Fqfjl_Oq+>D?LRS{gO{CAn)tQpr;gn@=`->;7E`m(k;ZWbcA9P4yk z0ft_f-WXAeIZ@cB7_ZlHH8v>wOuLVER=4%FkA$(20h=vm#?<;QY}RoNwx}2~?LlXD zmPb7!)XHlG^%*Z}N7cS}pvZf;B5Fyq$;gH=ENCh+ zV@7j(M>9-}V!?65h>o3#E=s!VD_@7Pn<^$#88d68at_xUb=;(=by9EiUxaZBbxfL8 zqL9kl9_1b#hN4tDZk%~l#|%p7NP;d4=iU9VxZ@SMXxTmW7{`Q$l#YGaPcFedvKZA> zMv~5*GYW4|GBP@{N=BXUI!gniP4~lkb1H3yQ4lP$3W<2eNM(r^R<2k`m{#02EqnE$ zOge%bY=uBuA~=A98V>20#BG8$#pY0)B=Njau*`xL-UbUQ5-dHf z?yl0lG{HiO$rZ-q2fGsSB!Sg`LoB+7yXbqk9{1w)8s4De@9{>#yt$STh7-(x+uW2k zmA3@#K_KzNzCxTwN@;Im2>a4T{cJjnH*0u{j<@0;1q&(@-cJt30kP1}w0WM}+YkLdUmK263X?JK`gsTV9F z8*(`o+bm=4Fdo(M8GP1d?jde}O66?SU*eTqFU^nYIEE<&rgVeBtl>6RQ1*HA1chmQ zPQ&MQJccij-wY`DBs6ovum-tB4kF*6R(w&%m+)mGan_lx+YFwnYnZS`7LF7}a9z4)lglXqzNZbd5E z1tV+i%@s0khHV=da&Z^#&5Y(sce!d8piJ!36rK3!L#^J z4gaO%zwtkUbLV1Fp-l^O-Q~Hxkjt9|n_#|j4zLQeQa*gqlh5Kg9sh?v5P8ZD5%jq0 zXFJN>>mG;G?04?Qad*P_lK>k2>^CJ&77ZngY*sZD&*N$J@uH5us@$me(tsTeQQ&!; z)VY}97*81~MTJ;5hcuWZ)k%g)T;Q+=R-fIZe>tXChK z!&1itbns2;Mc1T(t)4V;A5Md6g0*v~aC$JLRB6_wMWTcRh1w2`E`PZ`eFjD8Xql(L z!i7p%pvzgRASfn2eD2ZYY=0M=*3g4LC3LYaON0%11L=c!xgcnU50~vD>~rKiU6!hD zvf4`BW~zy0Z0cpX%J{w@$a+{s5RnzStW--Bfcr(xX$}udyDlB-RSjSDB{gCD?KbmH zyj)!<7?TQ)BeDurjLxCdc-FAl3<^5jZ7ienx|bk51+nEl2 z+rZ+fQg#*lJ*D#;{3DwVB}}LHwKTcP_qY=q zSBD&RTLbF)t2Ei@;h<}&I-C>=#XPHaK%j2r(<$5A3c=#P;k6O^RtY5<%<_Q0lPaba zJKrNS)w0|l&97*2{Kkz7J#+jHtXdsJ=*qyEp{%5+L*ZUlB=UC+_bU{4AUVbppc|)W z)Iu|F$J~aT<;CIlHi*$d&1)B0uK?a%fkWr~X zxhPcDdn!=Na|lZ{cPpUp47pbicn4t974C-4t{H(k=AA>xx4z87WQVnMPUeAyToKMp z?%-Knkq1N2D>)=+7_u2Lj8P|ZHJK2cJy%_Ibr#4z{`S#{X{R3yuS=x8JDiAH0#zeI zxlHxdiVx3)L`s{DjFBHO?TK8{YO0l6BT^8inXRfBA-n3y^CLu8F_x75+lBc~>?3_z|O6A{mNLj(Td|Z! z`Zr4d#9Jd4~Gl1t3t*5R)3 zxRFLKlglZgmWtgY-Q=iqb&ss0C$He@YD&D4za6sPle&vsm8px5pk-C`tP)}+oI4K} z9K%X?cnqiLu!LOC;dR})jt&dl^<^Cv%hj@hGJJWxeBLCR`Khe@KIJJp>}hoEK8m#i zosO7G9>?V+^ptQF$Gs(Ryt;%<9P~K@_vKcO2RWurC2Z$l$fvxXgI)gM1`cla2ct(Y z);Wc}A?%#lkq$(t!!mklIlXxS|E<7Uti%Rh&}~CIZ*w}3;w7EMYdW=S=eatUZM12l z@^ctzxkk3o1HugUZQRMRva!Y8$s_1CEU?n6RU~dJ%zsup}Urk|KL7qF^vIs zAALB5e+nU18`GxnAl*Zfce^CvSePUa1xUhWk`K5fb+I~9Lh zB~pI>arb?Fte)>b8DLTGl5qCO6iR|_J*H3LxbX7fY4!BD;Bj?YS(R?jH(_E$*a%oy(EsEwF0h*RF%`TTF8jC8LZv|+g zWg5@?)>x~e`A&eQ)uXA6HM&m^pIjQNiPcWwN&0^pPwkG?9L4v#^=bTYcjr<3xVzyP ze%jp_Yb@cH-83-zo9Hto{GOKTiueCU|JdC;jpr5Z3*A(_gugt1c{GwwFC7=cPIvRe zC!dKmD;TMAVB}joY=glb!6k&0OBq9#VG%EHSD=U2%mg@B0E_HRuBbtkzXzI`46IGX!OOCas!{jI4F4U|R6q6S1<$m6Z>XY~> z8Z?A89M+K2a6rSI8t&Ebwp0F3125ngCvh#JXSU!eO~y5x(D1B=)fx}Z{JO=*ch(d2 z^^%M4JbzU=HR+*g9Nv9YYG&cP)DoM0d>5^ARjY(uq&_B*k~FD_Ru8&megMa1AqO8< zZzNWdMO9ZWA+Ar!xxzcawR~JMCFh3}I+Wys&XTk}gcu9xk>DG*2;5aA51;&M=S)Ie zOx?lj&gA--+$OJ*+Y$SJuxV~L literal 7103 zcma)B33y!9b^gz2r1vy>+D69qfLV+!S(0T2W6UBc1}xiHAX&C0WDJhwrU4NlO~qeCY<=3+X}$?tkAhdLzrR zS)_OGJ@;()od2AA_3bxKKLy}Tax{hrYBWR*)S^z%a>zVvCbMRKDmgNF$Vxeay8cW) z<7^Vtbasu$prc+x%s>MSL2IgzOBSuHW!l#I^~o)_jR+cZ=ImHu*mSI7#>@&fbPl;p zOHL-69LnTptn_x%o*p)5`?`jz_XnH$l$a(1&1ezS+nM}S*1CImNYK-Hz8zhj5Lfe2 zr^qdR^<)w^(1s-fEmbJxsgXbi>#-EeG%Poez@=3tj~=rfD@RKUB^rK-$1+n$?j%2l zTrD%#7pLD=7`Pl)2$to{8Ec@BPnpi1j5EzI+cEQw&Apw2i)a+XRamLvY6GjVTF~bD zrJ6rgomJAZdBx;hqq@d5ba1KKaXZb_j5%e+(2g1%U4lp^9m87mXjo_98YHRfc@BZr zPFb|JBP`52d!En2aOl&pp2t2vJxH%kS;ZKx#Rdb{W1~Q)`r~G{WVsnWH^Nvt$y~V(-%31Z?y2GW_v02cN^8;)`S=x>* z2DT~*O(YA#h)X(drxuo(kD(uf2JXO}^zdP&-N?ZU8|_Du5-@CFhti{t0=AlY9Xkch zC1%D%;owA$2~aA!{@-n2RMEvrcUSeYj=N|_I+L^VcBVj;+OfyL-HO^E^_E~k$2~MK zZP}?}X4dg3_ZfJzqErTMnO{;tK4IVhOgetn3j@Yqi+6H<&e=|115!w9unZi;6uE?> z!RGPTnCbL_hzo+?9wj4V;ECQn?j3#DSp zvXhQwJJ%e|Wn-AZtU{XAF%&@#j)4*m3py2>qe+q^XU(E*7477fLaIbZIh#wFY}zVr zGgD5Xc#M9@TSo@nJWDaadOE!ry_mg3l_HKBIEJ_Ic*tgf2toVBa3h?2IF1i!_@IFg;lqNZ)i@Jm7UO`R;iV%r z^WEmv4PRyhK8lZN__%>zR$w3g$8Es6*s*sJ+_r2?Gz|VYaE>fluMrnfO$CjB|ojRC#gJR$Fw0BBFnO zBg`ys=3HiP+(EbGuDpd2?Jlkmp$e_&<|x)&c=f+)oK2ufv@0q6%Nx4CbNdeSVcML z&l40*;*^Ft1E+C@{N_O+AfcJlroDqleKf@L&pIf-=NMu zBvqoT9UoA*_e}$Ts2o;DFAz=D)VB;gqo(4VS^%7C`8x)_tCkJr;s7bt!sk_{HFs3;3aizfvIgBgXJzOveH}LlD>PpOyz|^9r0x%lLQ! ze{JAz@MHR#kQO5Gg8Tw9S{L@<3ETz6^97= zy!{Iu<(+k(%W2`7cW^u%9j^$W;io}A<7Uxl%FO3gKl3Vnpnm+1f&W#x(cq^68(5;i ztN1?yud8s>RT8MlI0SE~zVNKzri(M{TuW8D*Qg&isvo!L5@njXC?<8HX`-`(k$QUj z0@x+kxQGfDhCE7@215*KWa2AqcENJ>`MU0TtfV`oSwVsah|+3ET*1C#5`g4BO)d$1 z?e^(D$SI-A3|TG-q9Wc-eReVE7b zK0&v4j1>&-KTl!l+r)O)$N2LS`}pqCMh95sSfN#Pd8KyDoXm12K2%7V*>RKiD~|oi zs56~mgfKf<%>};mvGm7KjbJOW8H- z>Xgol@Q-ahnzGyu*Vd#r@VFZrl@%Vzw3W>kRF6EH%{ab?1S@`yG2<+|e&umhkE#Lh zKnt`CyshF+@eZ_}uUnN)<&vsqBWR(x(H9f+LQ!=kpt+&$-Iv0vC!H8Q$VQp`J$D4P zf?i5b@;>6l(nU41%&keUH73xz+$dOn6{W z8LG4kp+m-44 zsjUBE67vd?x*Jg@Q}G(bgSRsxnZtI%oE^5D=|b9Wu9NAQWaN-0Gpr%PgjqeGFPZ$| z!i=RF4?b&n&kdF9&_iK>^a(wt+s%ABYuT%Z3Wb@{tXB-H^4l}q&9zf{U3eL6a8q|rp~xOySK(hH5@RM0sv0|xHEr7>X6Zr8tqFsp z{T#y=vquwN8{NLev#H7g-*iTtXFOK&1{>kSO$~qZ8Vivwjv~^{F|W>*@mh}gUc@z> z<(w~KT{b_flK&#nnF;BuJ6ojTtzZjoD+tK_zdje9s&Hnw^Pb^_DqDBwBmI(mBpT5x?x zNNYt%Yvs%u{4--QC$$?D(YI3s11-{V1~Yr(xsxaipTd1R)|GLjH=2l+@z&njL~ZBBjEB!Wa;LYu>{&^;u1#3RuYI!S&lM50$n9`#7-6ZItd zbcm$BLbBH*i6vqr`CK3+R#|`CTW?4-aQ(MJEE+r#&VF$YCj`Al!k9x@@GyR;zP>7W z8tuJ})bweOM-xB4?tL~VniGv>{CRRcd0&s6U74s&)Xm|0^#2(=yEjpL z5`WrjoWb*Zdrso}y^W{vm%UAirZQgarGfFkjsJZa|42&>#rt35|JmDe2CpjG|LUdU zW&HQUSVAND_1bCt4Crln?Ci^l7KIiyE?Rt#5eL4e#&9#5(90O=V@mfk88%@(ZsEVT zVvvb2h5<}s3$oaTBe)&!#&$mG+<`}MCq9QEJi+J8(@d6cVJDu$ZoI-BZ(v;Nu}7BU zZn>I|kn3=-^kbiF!+zO?2|0iRatM=BVz>PO((*wZl!y78_&BEJ1P;kpF(Y3?PM+aI z;PWWRi0t z!o#M>a=An9RGAlv%a9BcH!q7c$PO7H*mn>Gc9LHmpSXW2yZEJHOrDe7{L*nmo{&*~ z)#DL4PTvgh1WrqqFFXTiptZYYOzz^}L|(*p8J9h1q~!y0x9p`wFQZ@Xk$cfh>pNW3 zZlMoW$Ub>9E!xlXybsZ{_z@a4=o*e|n9;yD@waJsK*LAR`R^p~8h(71ry0Mv4bN&a zq2UD$FKOu4czwn4aM@6Q%<=GD*3dbsSUq|M$M>ETEWme`!+Cs{NYC0fsqv8dl+>0b zrY0EdEC>B%X$j%Dv~lpbT9GAXSz5E{a^m`&@b535#zuZ#J|~w)6grgUs-Ci}dK3xP z$uEXiydv;GjXZYtn?3UhaUFFB-oYb!Cu_m|tOf7F4SW*X!jRvE_ptmv$Rv0#SKh~$ z#RvHk_I6xu%;1P;F@{p#?L2i)!vHKOKcIKb198((9z=#r|`+M5|$ z>Yv0J>7dg(pTuNM9PV#z`NZsOMzDRb`6g51Zs SIOpmpwRmenY$?eRB>o?F-aozo diff --git a/target/classes/com/release11/Main$1.class b/target/classes/com/release11/Main$1.class index 5233f0e5106106c16c6831e369df8f0f831bfea8..c2f9b5f14331a7fb67dc4eb4c545f83451a6e274 100644 GIT binary patch delta 766 zcmZuvO-~b16g_Wdpk?~7Whxy(v3y&mVEL@jiiky|P_2T|gha^Dj-;eaNvDvoFt{*r zY3f_Bb?t(LM8<@LVeQ6$WW3WfVdEro-~D>$-E-di9Q@v{|NeXV3&1=!+8{ypLE&gY zYkj{f89Xw}gZszJhjyV>s@M)gI9I6bC#qK2G97DTBC)iXPpj~w%?Fhu0M0NZ4p>)x zs;Bz~122}UR-u-1YG$>j5`2iG16uvlO7tc}V6V7SNI8|mYQa(wf$qaCjxKaF42zGl zUcU^A4z?PWaEGG@cNvtOO7WOsBqsV~!yiE}M<4pdH}+Z?WYERAtOryKdr0@1Ae|cr zNq9xatv1ay-E7S9#4JLy9AfhhjtCWRJv|JfKHn z|B-Lxjrb#%*ov4_GVHndpy+ZQFU6@ccEYo^ZB;X6({U^Zy#(*4n_{7mcR}Py^arp2 zhR5VhQ|x6_BYpv9{DkkEA_b@Kt26L=nSN%18}_3&@SywxPAV2%czR z7oAs#7%pzRh-w2ahOQ9PC?0)lcww+vGJb$*V=fX@Hnb@hGcM-5Rzeu{*7@ez*m^zJ zB%KW;5X3liOd^UY3}6NZl1Ofmlna=}D(0|`6gElDEqbWeB(|F*mI*|m(Vvmck}uJo WwMH(77kJgk0h+Y-LDC;LilgcF8^M~>&H#|-CE>4PYu3}(ymg{^Xd;=YO@ zhVuqY6Yt@DhD)~WTE1`v4@5R=ZF9#x z$`-*H!gwkU_3@7M@=;u1IDgb?+POgXeOts3$FhM-CO*JrhP8K#!w^xDVg0{A+4ZF@ zfH&BAr>y2R^iND&#VW&m&~qKd@GLdWMCoPE zr-OC+GeUK~ir-EUvyqloJ%v4cnac-NiaEBpkkAgDfCq>_B9#Iv~;`L0)?wa@#_ZW;o zD4i3-^ZzN@tcr@_0mJGU!tHYVn70MhT9K$`SgJUlsP?-};n#W7rImO^+T1w&>|z3k*DASRT{*c89EL!{#eH`piY$;J39M zAu4&cD+B83ZJ|1{W#B1+nm*S=8P6z>F1Zr2)DP40r4LB9stDAk45%|MY)GjB~09mCC9sZuJ|6PZMLZ)ZC}m$TM9(bz2Q zl@g~d{G-!K6cSlR7x9+o3BTy_AP^*3of>uOfLX~IAbwZ>-IOl=kO?HHmm<`%7(VIS z0fw(=X3@xKoX`9Q_Umx_AwBgrNRzMWX@&;KAx|^vY1)kpoqxgHaBn{oHwIXYFAZ?< z4dR&rRtESuerl699|<03~+0JEZLv>#qWpy+Tmhj3?@U^HPR*A z!3wgthP$|qd$@)BSjPiw5|~{)M4cdx0q>6h7syw`d`w@=b$XBB8*B{MiYSqE);h!LHWJAQS$QnVYIzc%L~9uHhC`lDg9);ps>r;R>k#FJvhu&e_7uXy-v~MhRsb% zepfF?E8MoYV{@0Pf56z=ch6=zAl2JmbH<|a-8Gif?r44P)NI4`s?A1Q5&vJEziy`0 zJO7}Si`UU)4~P|Mm|~m$vNdpMMsh&}ecTso_k4pEZHczwF)KYyP%b)Q$$j(xTBV6K zGKEz}Q>LS@ku5mpDrY*3YdCs`^Qw1URHQ7&id~6Kb+{IypIbjD2L(07ico0;&*$0U z&xeN>2C1>1$Fi{(q*>$ypBUi_qkNTL2*gcp3g7_`B?=3+i$@|j%4g=JQzO9wPk2g* zVcFO`&qQ>FqGX@T*fov__e&Xg5rB8|gAx-Zk(D)$mW-`l1@gf3e<(Bgg D{)~4y delta 480 zcmXAlJ5L)?5QV?Buf4|J0@)Ud8yYMc3S>o!B_s$4R^ep`kU$_oWMeO2UMBX2H<-K{ z1QOCMNRuCdD8L{gTKFL;Q>Q}AI=7g|IWu!+?p@+O9({Pcz6Cn@c^b|n*obKhIFfX@hoRCLf9Zw@tm^fldmnt7}uWaO}sI%3dORU z_d4oygh~CNT4L{*Hkq+_&jrUDd>ezYva7df=4fJ(fb5D`5hg5lN&hvQo-YgLXVA!sSgRg~SY=JJ21=|;&k`7eC``eA>1@R5 zO{p8~=}TVK=ns%mHHMA48#U+%r^4}x_}dy&L6Xc~G3OV!2ItZrz}FlnssBW>)izP+ zWP>iMyyS=;PU+)JzRlmJ|Gy%iDN7a+u9=E#7~=$wFET4FeuGVdWO3MHTeh^BV253~ kvr39R_T|C@=~vQOmCCOY2l&Q!XsUxYKLm;jZHt%p1ZZ+s5dZ)H