gryckiej/jacek-and-igor
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

files modified

Browse Source
This commit is contained in:
Igor Litner
2021-11-16 14:15:28 +01:00
parent 3d687e0845
commit 13b9381628
11 changed files with 74 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/com/release11/Main.java
View File

@@ -2,8 +2,10 @@ 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.builder.RouteBuilder;
import org.apache.camel.component.jms.JmsComponent;
@@ -35,24 +37,24 @@ public class Main {
connectionFactory.setPassword("admin");
context.addComponent("activemq", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
AggregationStrategy aggregationStrategy = new MyAggregation();
//DAO dao = new DAO();
DAO dao = new DAO();
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("direct:start").to("jdbc:source")
.split(body())
.bean(dao,"splitMaterial")
.to("activemq:queue:material")
.to("log:?level=INFO&showHeaders=true&showBody=true");
.to("log:?level=INFO&showBody=true");
from("activemq:queue:material")
.enrich("jdbc:source",aggregationStrategy)
.setBody(constant("SELECT * FROM package WHERE material_id = 1" + from("activemq:queue:material")))
.to("jdbc:source")
.to("activemq:queue:materialPackage")
.to("log:?level=INFO&showHeaders=true&showBody=true");
.to("log:?level=INFO&showBody=true");
}
});
@@ -61,7 +63,7 @@ public class Main {
template.sendBody("direct:start", "SELECT * FROM material LIMIT 1");
Thread.sleep(1000);
template.setDefaultEndpointUri("activemq:queue:material");
//template.setDefaultEndpointUri("activemq:queue:material");
context.stop();
}