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

working project

Browse Source
This commit is contained in:
Igor Litner
2021-11-18 12:44:04 +01:00
parent f04b77bc09
commit aaf2ee023a
20 changed files with 117 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/com/release11/DAO.java
View File

@@ -36,21 +36,21 @@ public class DAO {
exchange.getIn().setBody("SELECT * FROM package WHERE material_id = 1");
}
public void test2(Exchange exchange) throws InterruptedException {
public void test(Exchange exchange) throws InterruptedException {
HashMap map = (HashMap) exchange.getIn().getBody();
MaterialType materialType = new MaterialType();
materialType.setId((Integer) map.get("id"));
materialType.setMaterialNumber((String) map.get("number"));
materialType.getMaterialType();
materialType.setMaterialName();
materialType.setDescription();
materialType.setIsDeleted();
materialType.getMaterialType(map.get("type"));
materialType.setMaterialName((String) map.get("name"));
materialType.setDescription((String) map.get("description"));
materialType.setIsDeleted((Boolean) map.get("is_deleted"));
// System.out.println(tmp.getDescription()+tmp.getMaterialName());
Thread.sleep(10000);
exchange.getIn().setBody("SELECT * FROM package WHERE material_id = 1");
Thread.sleep(3000);
exchange.getIn().setBody(materialType);
}

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

@@ -88,7 +88,7 @@ public class Main {
.to("activemq:queue:materialTest");
from("activemq:queue:materialTest")
.bean(new DAO(), "test2")
.bean(new DAO(), "test")
.marshal(XMLDataFormat)
.to("activemq:queue:test");