modified main

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");