From 13b9381628b69b1a02ff2a34a4bb58d688d61bf0 Mon Sep 17 00:00:00 2001 From: Igor Date: Tue, 16 Nov 2021 14:15:28 +0100 Subject: [PATCH] files modified --- .idea/.gitignore | 3 +++ .idea/compiler.xml | 13 ++++++++++++ .idea/jarRepositories.xml | 20 ++++++++++++++++++ .idea/misc.xml | 12 +++++++++++ .idea/runConfigurations.xml | 10 +++++++++ .idea/vcs.xml | 6 ++++++ src/main/java/com/release11/Main.java | 18 +++++++++------- .../java/com/release11/MyAggregation.java | 11 ---------- target/classes/com/release11/Main$1.class | Bin 1717 -> 1927 bytes target/classes/com/release11/Main.class | Bin 2728 -> 2377 bytes .../classes/com/release11/MyAggregation.class | Bin 570 -> 0 bytes 11 files changed, 74 insertions(+), 19 deletions(-) create mode 100644 .idea/.gitignore create mode 100644 .idea/compiler.xml create mode 100644 .idea/jarRepositories.xml create mode 100644 .idea/misc.xml create mode 100644 .idea/runConfigurations.xml create mode 100644 .idea/vcs.xml delete mode 100644 src/main/java/com/release11/MyAggregation.java delete mode 100644 target/classes/com/release11/MyAggregation.class diff --git a/.idea/.gitignore b/.idea/.gitignore new file mode 100644 index 0000000..26d3352 --- /dev/null +++ b/.idea/.gitignore @@ -0,0 +1,3 @@ +# Default ignored files +/shelf/ +/workspace.xml diff --git a/.idea/compiler.xml b/.idea/compiler.xml new file mode 100644 index 0000000..6ceb844 --- /dev/null +++ b/.idea/compiler.xml @@ -0,0 +1,13 @@ + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/jarRepositories.xml b/.idea/jarRepositories.xml new file mode 100644 index 0000000..712ab9d --- /dev/null +++ b/.idea/jarRepositories.xml @@ -0,0 +1,20 @@ + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/misc.xml b/.idea/misc.xml new file mode 100644 index 0000000..5372e92 --- /dev/null +++ b/.idea/misc.xml @@ -0,0 +1,12 @@ + + + + + + + + \ No newline at end of file diff --git a/.idea/runConfigurations.xml b/.idea/runConfigurations.xml new file mode 100644 index 0000000..797acea --- /dev/null +++ b/.idea/runConfigurations.xml @@ -0,0 +1,10 @@ + + + + + + \ No newline at end of file diff --git a/.idea/vcs.xml b/.idea/vcs.xml new file mode 100644 index 0000000..35eb1dd --- /dev/null +++ b/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/src/main/java/com/release11/Main.java b/src/main/java/com/release11/Main.java index af9b711..10907d2 100644 --- a/src/main/java/com/release11/Main.java +++ b/src/main/java/com/release11/Main.java @@ -2,8 +2,10 @@ package com.release11; import com.mysql.cj.jdbc.MysqlDataSource; import org.apache.activemq.ActiveMQConnectionFactory; +import org.apache.activemq.command.ActiveMQMapMessage; import org.apache.camel.AggregationStrategy; import org.apache.camel.CamelContext; +import org.apache.camel.Expression; import org.apache.camel.ProducerTemplate; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.jms.JmsComponent; @@ -35,24 +37,24 @@ public class Main { connectionFactory.setPassword("admin"); context.addComponent("activemq", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory)); - - AggregationStrategy aggregationStrategy = new MyAggregation(); + //DAO dao = new DAO(); - DAO dao = new DAO(); context.addRoutes(new RouteBuilder() { @Override public void configure() throws Exception { + from("direct:start").to("jdbc:source") .split(body()) - .bean(dao,"splitMaterial") .to("activemq:queue:material") - .to("log:?level=INFO&showHeaders=true&showBody=true"); + .to("log:?level=INFO&showBody=true"); from("activemq:queue:material") - .enrich("jdbc:source",aggregationStrategy) + .setBody(constant("SELECT * FROM package WHERE material_id = 1" + from("activemq:queue:material"))) + .to("jdbc:source") .to("activemq:queue:materialPackage") - .to("log:?level=INFO&showHeaders=true&showBody=true"); + .to("log:?level=INFO&showBody=true"); + } }); @@ -61,7 +63,7 @@ public class Main { template.sendBody("direct:start", "SELECT * FROM material LIMIT 1"); Thread.sleep(1000); - template.setDefaultEndpointUri("activemq:queue:material"); + //template.setDefaultEndpointUri("activemq:queue:material"); context.stop(); } diff --git a/src/main/java/com/release11/MyAggregation.java b/src/main/java/com/release11/MyAggregation.java deleted file mode 100644 index afc04d9..0000000 --- a/src/main/java/com/release11/MyAggregation.java +++ /dev/null @@ -1,11 +0,0 @@ -package com.release11; - -import org.apache.camel.AggregationStrategy; -import org.apache.camel.Exchange; - -public class MyAggregation implements AggregationStrategy { - @Override - public Exchange aggregate(Exchange oldExchange, Exchange newExchange) { - return oldExchange; - } -} diff --git a/target/classes/com/release11/Main$1.class b/target/classes/com/release11/Main$1.class index 02c6665f7e1aeae28ff313d9a8823aec9e7e78ae..5233f0e5106106c16c6831e369df8f0f831bfea8 100644 GIT binary patch literal 1927 zcmbVNQFj_e6#j-LSwdISlG<3cDOwr<+it0Ctx(z+3Qa5_F_7RnK6r*@0-G#5ba#mD zKk?mP;0vD92Tz~0h+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{MiYSqUtrrDg6bIyL>xqbif;5Q^h|m7U$LrI!4MwFVYNy+LF7j5-yKC8Eiy~N5Xx_Fj|z#wfPQr zYQlDSUHJA~t6d=t6UPmlFwuv8hU+a(mDuyELfOw{9Etg+z|b?}1zz-!p))(SnL>ua zta?f~Q9g{giqZsez{F{sVd&aYvd%D*EpGEYZu>lNZG!0qZegqyV_jAWX>!@3*wU8} zt3nEA8IEmND^5O?v2sKj!#HQ)yon3ANMu`Jw~fQl5m8bf{|}V1l8y*NsSd%>^e&sY zf~!QYBCC|{v1}VMzjC+9{rFezDC5HzF>xKE4Bg?5??ntxvaOj|db^|OVokqI=qA4n z?S2SY3R#BZNzgUw1Lbi)4GZH2CQRJKE0X3Vc);-daIV%X+f?Ghe-yG^_6$t5 zYqTb#1J)(#gcNR3k8>yT_C$R*zZ;8Krq zZbyH=UbFz6v@f-W{(YDMqiqa4Ah}a(tnp7^*2E_m)@L01kQhFsXAchD7@4{%rs_(_6JJ&!3|Lyl10B54{0+`$6w;u-E?ox1t}Yk42* i0%7YSgp2fCruPm!!AhcAC9hJVStVc4Ewm%)q~A}w2h#-r diff --git a/target/classes/com/release11/Main.class b/target/classes/com/release11/Main.class index 0f05702a129b8845ebc4144e5e69c6bf247e7202..28c8fdc4224ab92059a77d35604a770972d8e143 100644 GIT binary patch delta 542 zcmXYtTTc^V5Qd+x-QBM3MxoTkdO!<{F)@ZTCYm$>F}e|vg8~Y8h^}RoB2e6}cy>MB z7)?yR3;hXRO1RK!LcG;K;qUOqI9r{InRn)$^T+K!^4Xt%zHR~oyjst0rrkoVvD_a9 zOM%}EDwX~*zrNyDvUsF(3~}0Fgflucj_eq77{^kW&BzaZT<+U9~Tn!Q_Rnagm|;S!e>W&O)2>jiTtcMU(ob%z@Bdc*7~B;9T}+)Vl#&8V@O zp}ujzdZY9qE*`!mvBZN8mP9*kY_iOXcw1<&Dm9Cs zMli@o?1TPo`*F$mhBx<_Q!R#5l#CXms%<6|RjXv>r}F1p%%mxB zlS05wY<7`jw@lwdk#0eIaoNWq${eMKD!uYemr?qdVn03yWv79dH3o?}#%qrAj+4BX zwB&%{e@k+kP&`|>Zklpbj<-bIk@2qBHSUs@0Y3M*FNb;3`~eT;H8CX~@mQYnMCuKx Yj3x7#;1th!@juq-@ls$`Xiu!jUp3cSk^lez delta 885 zcmaiyTTc^F5XXN@FI(D;7s{=os6f0CY>0^_1)~T=w5^~Bf+DiEYbo{u+XciMc)y{d zt3LZ=d@wP@L_`wa^&9vd_zcD=V3hdaZZhYb`Op0SGjqs@qA zR>ZRDplPHGJ!jO{2cr{BiG*n+bSs(7cxlC&INCp2=?zBwZG7=LFySsfH=A_0cI_)LL z{_-x3Zrlp4oTZyq9_-QR<*XfYHv9V&w0P1qVpeDw_Rw$7IIDdF=qeXAV#Mu5XWTbP zQe{ZvGAX;xRn_Ssqfn;DtmK%H9tn+%8ly%iEfttaJ>_G7VT}>iE0p96tHrpakEX2F zOnf+-%vfD!GG9eb!^+p?%vsrCm9bAT*R;~(*Z)lOcTWmCR-6A%?+T8%o>lPwJ3f2K z-K4y*_p0swQ3~Wb5i3K%Eq2_VQA_t-5nuiU>zEL$E$>}i<(ixdxy}vA83*N&2{c>b7A271h}8)W>w%}^5aW~ff55&Y}q>RAqG zJk`!fH8XMy6%+LrRcIO6+E_jPXv-Zlu~J>@bjUw@J9dl5K76_d4ME3oOgAB{P{fHD zapCX{>@`hS30>OZGGTQlzzS*<(Jiq?=*;KD9&zsI#UUvd&Qj{!n`P%tr>J8+t(L