From cd861c7b87fcc1dbd570434734505abbe4a27c97 Mon Sep 17 00:00:00 2001 From: Igor Date: Tue, 16 Nov 2021 18:16:24 +0100 Subject: [PATCH] dzialajacy package --- src/main/java/com/release11/Main.java | 22 +++++++----------- src/main/java/com/release11/MyAggregator.java | 17 ++++++++++++++ target/classes/com/release11/Main$1.class | Bin 1698 -> 1783 bytes target/classes/com/release11/Main.class | Bin 2456 -> 2427 bytes 4 files changed, 26 insertions(+), 13 deletions(-) create mode 100644 src/main/java/com/release11/MyAggregator.java diff --git a/src/main/java/com/release11/Main.java b/src/main/java/com/release11/Main.java index 1404495..bff3989 100644 --- a/src/main/java/com/release11/Main.java +++ b/src/main/java/com/release11/Main.java @@ -3,10 +3,7 @@ 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.*; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.jms.JmsComponent; import org.apache.camel.impl.DefaultCamelContext; @@ -47,28 +44,27 @@ public class Main { @Override public void configure() throws Exception { - from("direct:start").to("jdbc:source") + from("direct:start") + .setBody(constant("SELECT * FROM material LIMIT 10")) + .to("jdbc:source") .split(body()) - //.bean(myFunctions, "splitMaterial") - .to("activemq:queue:material") - .to("log:?level=INFO&showBody=true"); + .to("activemq:queue:material"); from("activemq:queue:material") .split(body()) //.bean(myFunctions, "getId") - .setHeader("id", constant("${body[id]}")) + .setHeader("id", simple("${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"); + .to("activemq:queue:materialPackage"); + //.to("log:?level=INFO&showBody=true"); } }); context.start(); ProducerTemplate template = context.createProducerTemplate(); - template.sendBody("direct:start", "SELECT * FROM material"); - + template.sendBody("direct:start", null); Thread.sleep(1000); //template.setDefaultEndpointUri("activemq:queue:material"); diff --git a/src/main/java/com/release11/MyAggregator.java b/src/main/java/com/release11/MyAggregator.java new file mode 100644 index 0000000..f82b885 --- /dev/null +++ b/src/main/java/com/release11/MyAggregator.java @@ -0,0 +1,17 @@ +package com.release11; + +import org.apache.camel.AggregationStrategy; +import org.apache.camel.Exchange; + +public class MyAggregator implements AggregationStrategy { + @Override + public Exchange aggregate(Exchange oldExchange, Exchange newExchange) { + + String oldEx = oldExchange.getIn().getBody().toString(); + System.out.println(oldEx); + String newEx = newExchange.getIn().getBody().toString(); + System.out.println(newEx); + + return null; + } +} diff --git a/target/classes/com/release11/Main$1.class b/target/classes/com/release11/Main$1.class index 943353ecdc32231fd3532fe7186d07ec3ad00646..06d02fcbf66fb55a10acb8d49af2fc4fe09e75b0 100644 GIT binary patch delta 669 zcmYjOT~8B16g{(D+U>G{U9c6=vT8xP2>lY2R;p5pR$5zWwMOkjKh|VTKS)~=jWN9I zQ!{@+{Rf6*O?WW8=!3t)Xa9h2#=8ZhGs&EL&&<8|+&dq~evQfBe;yS+BroO_ zT*d-_&q|`s;NwZrH!9-_{4Ok=)JPO}n`VF0cy6}MzS(I@2r&p|LqdeA2434qpPG%z z8(VEm!BwmajOd@iK9M0HO{a56E@F#p<@f>a;4XO#8M+l<2OmHj-c@wfWx=hh6Baxc zP9MRm&R954s9U&TVNMNNSS;%{xc^f7%eor25Vf#+gt)HW7zQWFR&QFkZQ}-E`JbvN zX|W}{5yliEm_d~OEk+--f@Q2?ji!~Rvp}lMe1t4qNxqHbIUY0r!y~ Uk_GJG;gBid5ur@aWI|eh0Nl2HGXMYp delta 573 zcmYLGO-~b16g_V`ZHHk+<#|A4hZ%Zo=XGY*w%%K|nO$2f4AtK_ALg9OC-YrxkFJWLO@m-isud0Q z7@A{WO2odXR$lJw&@pNtfd`GVoYs$&fiaBBZvi`?VM4~$F)fBk1CNlAAK7y@Ela8( zYDRunzp^D64bFGv8F<;*Nz^RcD%P!JGO=2$?iyG_LGA|&2eY(;1Q;D4D2~8>P@v#3 zy+eL+6i+BNE(DmvJY@_|iB;e=A3^oGqTpc{O+4bF^#okFXm`=Yqb~YR5aUBG?miP< z+H^(51s^$ZaopWT&qnE-VWl zz@-o33kc#d3f>E6=FXWpb8bBAGt>R{_3{d|61{idT4^2z8FCo*GQw!=-J14HFzGPm zWty2-n_Zhe=VhK0gB4z12{{BGw(JjMPGhr9&q#nIX(2S&qzD)EYE(3ecHJZ9K0z-E ze`rW!N$CA;V3`%YQVFpt5e=JhEL^JH#WGx15%bJIGTDqhF?cQ!d1}wc zLjma&l1mZAy494>Kq<|X(Ly;sD(I$?KB}0Yh9LE9(?*1LqI7UgCvm#C#h)RP7=@o(zVel-T8Jqz7rF!qy_86-D5)4CL8P_Plv$xoWgf~r#qLXlmG%=v zqOtG;{1`hci8#f=UA)6N=RNnm_buZh)BF7X_yp8*dgHyaDn0ZVaymn;p@yzNRiLS( zy)7^ujgQPvM5lc860zy?^M`)t&KmX&F>Ev9XOuA~=q^v6@Dn4|U@gRFW^JZ!d)+U_ z95~H(dt?%q?m^MuCRK4--A`qs?5_Hcx%s63Dkf=2XGYQgC1930b!p7AAQKInC>9=J z*UqbbmdN<^!0!~Y7`SIJ*Lq;w@a@=5wv>6&=i{S5-i72)q^g)71gNHjT1u&-jF6C4 zf^XP9mtE`ct yOJb}`ZOJSmbW6Vx6PjRK&psxX9d@zVlanQnea#%Ic5x*33k!3i$}2Xktn&f!%ttf;