From 25103f8819060187f030546da84f4448269cc9ba Mon Sep 17 00:00:00 2001 From: Igor Date: Tue, 16 Nov 2021 15:10:05 +0100 Subject: [PATCH] change code --- src/main/java/com/release11/DAO.java | 10 ++++++---- src/main/java/com/release11/Main.java | 9 +++++---- target/classes/com/release11/DAO.class | Bin 7235 -> 7409 bytes target/classes/com/release11/Main$1.class | Bin 1706 -> 1698 bytes target/classes/com/release11/Main.class | Bin 2496 -> 2456 bytes 5 files changed, 11 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/release11/DAO.java b/src/main/java/com/release11/DAO.java index f4165c3..b0abf50 100644 --- a/src/main/java/com/release11/DAO.java +++ b/src/main/java/com/release11/DAO.java @@ -1,5 +1,6 @@ package com.release11; +import org.apache.camel.Exchange; import org.w3c.dom.Document; import org.w3c.dom.Element; @@ -25,10 +26,11 @@ public class DAO { return xml; } - public String getId(HashMap packageMap) throws InterruptedException { - System.out.println(packageMap.get("id")); - Thread.sleep(1000); - return String.valueOf(packageMap.get("id")); + public void getId(Exchange exchange) throws InterruptedException { + + String tmp = exchange.getIn().getBody().toString(); + System.out.println(tmp); + exchange.getIn().setBody("SELECT * FROM package WHERE material_id = 1"); } public void splitPackage(LinkedHashMap packageMap) { diff --git a/src/main/java/com/release11/Main.java b/src/main/java/com/release11/Main.java index fa9f917..1404495 100644 --- a/src/main/java/com/release11/Main.java +++ b/src/main/java/com/release11/Main.java @@ -55,9 +55,10 @@ public class Main { from("activemq:queue:material") .split(body()) - .bean(myFunctions, "getId") - .setBody(constant("SELECT * FROM package WHERE material_id = 1")) - .to("jdbc:source") + //.bean(myFunctions, "getId") + .setHeader("id", constant("${body[id]}")) + .setBody(constant("SELECT * FROM package WHERE material_id = :?id")) + .to("jdbc:source?useHeadersAsParameters=true") .to("activemq:queue:materialPackage") .to("log:?level=INFO&showBody=true"); @@ -66,7 +67,7 @@ public class Main { context.start(); ProducerTemplate template = context.createProducerTemplate(); - template.sendBody("direct:start", "SELECT * FROM material LIMIT 1"); + template.sendBody("direct:start", "SELECT * FROM material"); Thread.sleep(1000); //template.setDefaultEndpointUri("activemq:queue:material"); diff --git a/target/classes/com/release11/DAO.class b/target/classes/com/release11/DAO.class index d89e9a924960f727cadfe033b992221e4fc96331..bbe88b69e94f3b0e0b8b8d9cc133a5338da71614 100644 GIT binary patch literal 7409 zcma)B33yc3b^gyt=#55C+X!sN*hUx(k`SH%!Ha~kK?oyTLV$!YIJS72c}N4ZdEOg9 z&SLD~CC=hB-3-}ivp8)QC%739N)snd+Bj{~)=ksJjhoc1+q&)7#dR0gG5POXMsFk$ zKxp*tednHY?pgkG?w#+wb^hxBZk6{%5JHuPY8?wuBWOBg95Lc)BRd`+96MwtY(dS& zR5oRA5>&Odk3I_QGtL@pCAm}%3n%(ZLdTQ?61>N7@uI5%L}W+7#y1?$`T z9i~M)m5%qPvWLy&cEg$&F!J5){gvzeMcqnFgN{Zt32LoWc06s~J{OqlV6kulTp-eZXg?$i`47&q;{tl;Xl_Wn6! z1Eyse<0knnMohz1I+oyS!QzV%3N*6Yl1oks7Lws?lX7<)L$~CL^wJ_%Oez=O$<5nbZ5kO$YD2q*4jrq}DQIz2sidK{ zd9@|_x238cC>EWJvh)xGajZ*TK8`6-QC-o@ti%HO19qG zx>gzLZ93Ls9hqCcDJqz|!PVV9qT%h7TNwsBUFH$2M^zX%2|}r41h=3|L${8N3|m}z zk&vP}XnVoR;7)vDb3LKqHU{yGgZi?zIc^pr*o4hGwxEX&qHRWubdgcQ1n5&r_3GG$ zI~XOLsW5VeAyt1uUq@cIy~Y z5*kS6Ck2fg#vW>68rcZ$#9keDV;?PiL}@p8@Y0+1LP`m^N5?yq9yJuuYh=T?PtaIo zo{#1Zj%Jw7#e%8m4(KoxU6gctDqn|@;69S6jG47kIjXcCrjCP(S|{~Z|3w%R++fnQ z5`|RW_9zeOIIJku2Di?}9)eglQ}KS#%9airMREy7gGKjO z8A(TDFl*Fu*!Jw78tL%?d(@Btkk#D@gS zE~&e#v@eY~=was3^@(_r<-mW_9ma?0Mc=}8_y~Sc!!POhW&8@kPNC=QB`h8Z;+Adp zrcGrnL3=Qdz4&z@+F$FDQrc4tVPD#)n}`vd!bdfHOvlF+*j`bIGk#_<4hR}t5@hWJvDS(c?vG5fNP zuP7U++O)%)dsfG9sksKu1+p-Vk|2_@Mw6`Uwn^+gg>yQlaGs1w+E;#~ax7Tjw&Zf` z1+omPQ}~*W-^SNn<{qN=r&MxA{Uw$8{G5(&;#&%EX$FJoL4Q?H_IdNn{%_+u8h%&D z@8P@THJkNXE_}PG4K0S&I6fpysXDZ6_Wjlju(_= zYPenEqni4Gjz3dVQBKW*LiPI3b^L{Ttt(sl*r#4Rt0Mo?8veQ>x$J_GwGQSA88>GJ z2ZkJUiQq-Nq%h@g9Qc|ODXL)pM6hZmOJ^8aPR)#L<<4ydOSW-5Kpxa$P+fc5ryB$um-?@&X zcfziiwYthcvm) z_kzsqw5~ zv%M2^xU$MHyzwHnrF&C1EAb_WJ&1Q`t9w}JSdCTOxn*_O7)x^|+Mi1p=@Ek`Lyo=4 zYI`EZ&}*3`org(^tybNZV2x)@PuI#rq)Kh~%<3g1)4^{9c+BL{uR{0WVzw`{#QN5y z>?(F}O6Pg_M|gHLoo?3BgpIm;vT|ah{D!#IHup5?A3B-g%ucg>1YPoTNU4gQ$!jv; zL7}@@byz7Big{M(fK1)Wr&G4)4RxZu=-!nA5wHF^W~x>LqQfkU_?}fUu6X+vnyH@U z#%NJRZ{xRSTVvFMHdTZJmsN+5HjU4qEdl!k*KWy zRG@|@4VG@YE}-uWxmO=}D7I+|*SoW8NT9BHCk^tgEAuefS}mKGd0-(|gfo-7O@qf3 zm7Goz1WOPJ>W6Gb3}eU1WKBqT)qHi<)tRn6#9tnhtJ6*+7~Ysjdv{9_wrnRC!mpfd{yJfioPu$Hr*F>9+$fJ@~mNFg4HJgU6!BNT-L` z>vo6bAx4M@%eLO9ihEDmuq>0181|cbO&;NSZq7dEQ(u$EDo~#1`#4%6dEa*53`HHioi=TYW&!}|sQ+Eku zquk1o$R@dsjMd`%D6X1+8#-2(pbd0%mQcTA&6hb762+wfRs38`ZZUGX%Hh`GuJE{# zMsAnQlu$#(J}g_vQRnI&*-A_Ha&F=dh`S+e_HW@pfl?X9@ir3cAlH3VAn# z6xP7v)t~aEyIZ@wTU&NI)(;~syJR;lD>78x<6h6w&8~mX;K&>WTo!cqz$L=i4bBnF>MN;qIpR2v`Z3>g-P-o0g`Z;gjpG zb6DS1Pfh>8<$KXe}(V~w%;68@;nuOZf07CG$FG{u?}%^wG7n#wfyx-`wPW<~R- z0h;DA&6rCQjYSpB4+AvOGL5(WmRO6T`O5%Ji$_xvYjB^QzOXE|AXYPlzoPx8@#4PN zg0uKhmp+Xj@9R8^zwN3&hrjP?h&7b(Y8N*c{rBj9mhfNPsjhgx5q+zxX<9&933XBN zl2o0=ih1Ymv`xftKYcV2= zu~)9+-Rv6dmyNiGKyKkT+oytc#%tj)bB(8d}avOO-iq5-8u|UCXfSAu!hBSsCF| zBjrCyjrQE%*>_O#9)k2qESJ0a)I!~#mwim*dX-Op{)JXLS;rnRbhYf4 zdzjP>p~dnJxmRUgC@S~KD8X?_s7?-u!P>BrC@@BTHCQXJi;|&XSYD7MpLpde&xpyV zS{_+Gz$@WB^uT#Z^QvhN>bTq8a!|(kozhF#E)$YMJ$K&2hT$-G^eT@>Y003GyI<*m zd=qVOwPYp79p!0(`%!%XKSI5Ru!d6_CN&(_@PvksX!zuu|KA4Qz)vpFlhMmt@S-O7 zYj{P&>l*IVRE=9)#&=d3^<|ig@3M-b;}(GvRr2(O?{v;2#5(E@JV+NEXDxV$wcugg$Qz-pIKi-fgw^^{Cc$HzeH>5m z`4f1;2|87g4`7p6VmlS>v>!M)Ek&<7JmmtnuYa}?!#3+24` N_L!WIN9A$Eeg-Dzp=tmC 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 diff --git a/target/classes/com/release11/Main$1.class b/target/classes/com/release11/Main$1.class index c2f9b5f14331a7fb67dc4eb4c545f83451a6e274..943353ecdc32231fd3532fe7186d07ec3ad00646 100644 GIT binary patch delta 773 zcmZWn%T5$Q6g}0`I78FC8e~*Z1cm_{WgKL942+1Qf;FRY8perO>Yl*`;UYs=mSIz^ELroIfSV}Oj^P$%wfOJ>^fz$*e6nY&ef^)@CEFT`a3w;X7`9c2{c**fBDTWP3C5@YDjOj^ zzzCXY=xG$tjWP6L0yd4XfGJWujV1b`k8vH(Nab^is4mLKZSa#eZc|8!ze9GOd<}Q8 V5XTm=jFmXDhzEoQu?#|5zX8#2mOKCe delta 771 zcmZuvO-~b16g_V`rDgiCWhxy35ru;76fJG}EFvO^d=#o+G$AUPwj&u*rlc(-#04Ao zrg?urUAi;Mn6NOcT=*+o`v=?^?=($_i8Gn|?!E86bMHBCK6HHS(0=?m`vzbZTkVkG z@j>SBqOGytJrO)I%F+Gfr9-<|w<>mxA)G5#_LEh!Y#KE)l}awo=Vui7(e8u75ddcx z5(liik?HHX#K22d)hyPtwYpKQD+C|n=!DvMv)q4~A+T2}6tlI;VYO%~h(Pn<3P(43 z7>319kJdN~icYo~mT;A$57!vvLZx)f5RWz9hs7^R^G9%<;|2!AJN875GHBwitOXPd zyI?n4I9*!@WvjkuzOrn~<>5oz9g{kU7gC5Nge?t>$DsLfo58zl)>ld{!YD@yX}76q z*bJMo+@5h{B+G`qo6HyXh}TTxZ9@F^MC37sgm~@I11Xo}1ji(%gd?r_W5{yM;Ewq0 z*%nzjszqY|Q84~gJeMuDEWXPNz3U9>zap<2md%mJBN6q^o=7A&z(OJSmdKOn3t$cm z_sAQg*v%+<;uK8(3g0J+B+Qd-qZ%NA`(%03SFnIZiWnYHMrtCQ!qeQ_(bWzIK{f24 z>l_i?L9c^;^<>b&&^cl%B}Sg1~k?G2LiCH<`zBz9UPmIy?q(I1jsAzz|H WYt38^8+hEzHuXnrF%eys%T1}au`^G9qE`=j-B$f zPRd8bsFP7%$}0NIh}rt0^<|wYKW)sPvC#amtT+~>k9B=zJ*jo^o*`<)IUs>1$zM_& zlJ*>A@3-LcMl_ai4|yxDY<}}jls+D@#Rop(Cng7f;+_oZUjUBn_fC#&M e!DLS+88TyEG~c40mG45|gGqi!6%slrS>7EClU6JM delta 511 zcmXYt%TH5L5XOI}y|?$$o&^FnbVIr@26WMMqXA-K1wzqc0ih})QrZiGKuddh`oK2` z?ruy-*x?^whzqC-;+my@h#U9BY0FuBb7sDId^7vazng<+=f6&YTYNnV{_}U-)0m_b z;r3Lnuox>j3r@D|#N)BvM7p~p6XG`aHED)C+qls>qIp0-VV2!&$*q!OnhX!UjL{Q* ztkC(nl9O}0YP8K0MVt4-2w#q-1_lR4qwx?=nY4JOnIh}`G4dgY8H-uXbLPB+dA0F{ zW}!O4D7%HC#nR6;^RH6d-i(!=Si~pF5flXk1PkKD#454owPVy#jV=mSX=r3wP}dVE zQ5LTOmlbIu#VUt^EwS(3CA-)e2^@2`!k~|cQDIos%&4NvidapLn#LEjApyyO*r zZpsZ_^G3AwF)7ivvhF;c()+#awM&E#e8l3DbTXvJXQ|nVisR#p(Dh)FJ^2NNPKuTH EAKlklEC2ui