From 3daa3abf3a4a3b838f18348e482632ec0e9f3940 Mon Sep 17 00:00:00 2001 From: Igor Date: Thu, 18 Nov 2021 14:07:50 +0100 Subject: [PATCH] working --- src/main/java/com/release11/Main.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/release11/Main.java b/src/main/java/com/release11/Main.java index 9e4fed4..1a61c72 100644 --- a/src/main/java/com/release11/Main.java +++ b/src/main/java/com/release11/Main.java @@ -50,14 +50,14 @@ public class Main { .setBody(constant("SELECT * FROM material")) .to("jdbc:source") .split(body()) - .to("activemq:queue:material"); + .to("activemq:queue:RawMaterial"); from("direct:getPackages") .setHeader("material_id", simple("${body[id]}")) .setBody(simple("SELECT * FROM package WHERE material_id = :?material_id")) .to("jdbc:source?useHeadersAsParameters=true"); - from("activemq:queue:material") + from("activemq:queue:RawMaterial") .enrich("direct:getPackages", new MyAggregator()) .marshal(xmlDataFormat) .to("activemq:queue:materialPackage")