diff --git a/src/main/java/com/release11/Main.java b/src/main/java/com/release11/Main.java index 644c85f..eeb9633 100644 --- a/src/main/java/com/release11/Main.java +++ b/src/main/java/com/release11/Main.java @@ -66,7 +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");