diff --git a/src/main/java/com/release11/Main.java b/src/main/java/com/release11/Main.java index 5bce488..644c85f 100644 --- a/src/main/java/com/release11/Main.java +++ b/src/main/java/com/release11/Main.java @@ -56,7 +56,7 @@ public class Main { .setBody(simple("SELECT * FROM package WHERE material_id = :?material_id")) .to("jdbc:source?useHeadersAsParameters=true"); - from("activemq:queue:RawMaterial")//subskruypcja + from("activemq:queue:RawMaterial") .enrich("direct:getPackages", new MergeAggregator()) .process(new ValidatorProcess()) .choice() @@ -66,6 +66,7 @@ public class Main { .to("log:?level=INFO&showBody=true"); + from("activemq:topic:Material?clientId=1&durableSubscriptionName=FilteredType") .filter().xpath("//material_type='A1' or //material_type='A2' or //material_type='A3'") .to("activemq:queue:FilteredType");