diff --git a/src/main/java/com/release11/Main.java b/src/main/java/com/release11/Main.java index 253a7cc..a01c67d 100644 --- a/src/main/java/com/release11/Main.java +++ b/src/main/java/com/release11/Main.java @@ -1,7 +1,6 @@ package com.release11; import com.mysql.cj.jdbc.MysqlDataSource; -import generated.MaterialType; import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.camel.*; import org.apache.camel.builder.RouteBuilder; @@ -11,6 +10,14 @@ import org.apache.camel.support.SimpleRegistry; import org.apache.log4j.BasicConfigurator; import org.apache.camel.converter.jaxb.JaxbDataFormat; import javax.xml.bind.*; +import java.io.File; +import java.io.FileInputStream; +import java.io.InputStream; +import java.nio.file.Files; +import java.nio.file.Path; +import java.nio.file.Paths; +import java.util.ArrayList; +import java.util.List; public class Main { @@ -40,8 +47,7 @@ public class Main { JaxbDataFormat xmlDataFormat = new JaxbDataFormat(); xmlDataFormat.setContextPath("generated"); - JAXBContext jaxbContext = JAXBContext.newInstance(generated.MaterialType.class); - xmlDataFormat.setContext(jaxbContext); + //xmlDataFormat.setSchemaLocation("/home/igor/Documents/Jacek/jacek-and-igor/src/main/resources/material.xsd"); from("direct:start") .setBody(constant("SELECT * FROM material")) @@ -69,29 +75,30 @@ public class Main { .to("activemq:queue:ValidMaterial") .to("log:?level=INFO&showBody=true"); - /* - from("activemq:queue:ValidMaterial") - .process(new MyProcess()) - .unmarshal(xmlDataFormat) - .process(exchange -> { - MaterialType material = (MaterialType) exchange.getIn().getBody(); - //MaterialTypeType type = material.getMaterialType(); - //exchange.getIn().setHeader("type", true); - //if (!(type.equals("A1") || type.equals("A2") || type.equals("A3"))) - // exchange.getIn().setHeader("type", false); - //if(exchange.getIn().getHeader("type").equals(true)) - System.out.println(material.toString()); - }); -*/ + + + from("activemq:queue:siema") + .process(new XMLProcess()) + .unmarshal(xmlDataFormat) + .process(new XMLProcess()) + .to("activemq:queue:test"); } }); context.start(); ProducerTemplate template = context.createProducerTemplate(); - template.sendBody("direct:start", null); - Thread.sleep(1000); + + Path path = Paths.get("/home/igor/Documents/Jacek/jacek-and-igor/src/main/resources/test.xml"); + ArrayList readAllLines = (ArrayList) Files.readAllLines(path); + String allFile = ""; + for (int i = 0; i < readAllLines.size(); i++) { + allFile+=readAllLines.get(i); + } + + //template.sendBody("direct:start", null); + template.sendBody("activemq:queue:siema", allFile); context.stop(); } diff --git a/src/main/java/com/release11/XMLProcess.java b/src/main/java/com/release11/XMLProcess.java new file mode 100644 index 0000000..04535f2 --- /dev/null +++ b/src/main/java/com/release11/XMLProcess.java @@ -0,0 +1,14 @@ +package com.release11; + +import org.apache.camel.Exchange; +import org.apache.camel.Processor; + +public class XMLProcess implements Processor { + @Override + public void process(Exchange exchange) throws Exception { + String tmp = exchange.getIn().getBody(String.class); + System.out.println(tmp); + exchange.getIn().setBody(tmp); + + } +} diff --git a/src/main/resources/test.xml b/src/main/resources/test.xml index fddd6c3..70e09d0 100644 --- a/src/main/resources/test.xml +++ b/src/main/resources/test.xml @@ -1,13 +1,16 @@ - + + 1 number8186 Z3 name2686 description7225 true + 1 + 1 number2274 - 5903339152912 + 5903339152913 unit1350 18x30x18 description7460 diff --git a/target/classes/com/release11/Main$1.class b/target/classes/com/release11/Main$1.class index 56e9947..1ffeefd 100644 Binary files a/target/classes/com/release11/Main$1.class and b/target/classes/com/release11/Main$1.class differ diff --git a/target/classes/com/release11/Main.class b/target/classes/com/release11/Main.class index f62d36b..b5cdf0f 100644 Binary files a/target/classes/com/release11/Main.class and b/target/classes/com/release11/Main.class differ diff --git a/target/classes/com/release11/XMLProcess.class b/target/classes/com/release11/XMLProcess.class new file mode 100644 index 0000000..2aa8e06 Binary files /dev/null and b/target/classes/com/release11/XMLProcess.class differ diff --git a/target/classes/generated/MaterialTypeType.class b/target/classes/generated/MaterialTypeType.class index 31495ce..37556ba 100644 Binary files a/target/classes/generated/MaterialTypeType.class and b/target/classes/generated/MaterialTypeType.class differ diff --git a/target/classes/generated/ObjectFactory.class b/target/classes/generated/ObjectFactory.class index fa00d5d..31f828c 100644 Binary files a/target/classes/generated/ObjectFactory.class and b/target/classes/generated/ObjectFactory.class differ diff --git a/target/classes/generated/Package.class b/target/classes/generated/Package.class index 2556224..656d9ed 100644 Binary files a/target/classes/generated/Package.class and b/target/classes/generated/Package.class differ diff --git a/target/classes/test.xml b/target/classes/test.xml index fddd6c3..70e09d0 100644 --- a/target/classes/test.xml +++ b/target/classes/test.xml @@ -1,13 +1,16 @@ - + + 1 number8186 Z3 name2686 description7225 true + 1 + 1 number2274 - 5903339152912 + 5903339152913 unit1350 18x30x18 description7460 diff --git a/target/maven-status/maven-compiler-plugin/compile/default-cli/inputFiles.lst b/target/maven-status/maven-compiler-plugin/compile/default-cli/inputFiles.lst index 0aeaaff..91e548f 100644 --- a/target/maven-status/maven-compiler-plugin/compile/default-cli/inputFiles.lst +++ b/target/maven-status/maven-compiler-plugin/compile/default-cli/inputFiles.lst @@ -1,4 +1,4 @@ -/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/DAO.java -/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/MyProcess.java -/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/MyAggregator.java /home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/Main.java +/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/MergeAggregator.java +/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/ValidatorProcess.java +/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/XMLProcess.java diff --git a/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst b/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst index 3006cd6..c64bbd3 100644 --- a/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst +++ b/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst @@ -1,10 +1,6 @@ com/release11/Main$1.class -com/release11/Main$1$1.class generated/MaterialTypeType.class com/release11/Main.class -com/release11/DAO.class -com/release11/MyProcess.class generated/Package.class -com/release11/MyAggregator.class generated/MaterialType.class generated/ObjectFactory.class diff --git a/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst b/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst index da45fbb..abf5e75 100644 --- a/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst +++ b/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst @@ -1,8 +1,8 @@ -/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/DAO.java /home/igor/Documents/Jacek/jacek-and-igor/target/generated-sources/jaxb/generated/MaterialType.java /home/igor/Documents/Jacek/jacek-and-igor/target/generated-sources/jaxb/generated/Package.java -/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/MyProcess.java /home/igor/Documents/Jacek/jacek-and-igor/target/generated-sources/jaxb/generated/ObjectFactory.java /home/igor/Documents/Jacek/jacek-and-igor/target/generated-sources/jaxb/generated/MaterialTypeType.java -/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/MyAggregator.java /home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/Main.java +/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/MergeAggregator.java +/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/ValidatorProcess.java +/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/XMLProcess.java diff --git a/target/site-webapp/WEB-INF/web.xml b/target/site-webapp/WEB-INF/web.xml new file mode 100644 index 0000000..5045c3f --- /dev/null +++ b/target/site-webapp/WEB-INF/web.xml @@ -0,0 +1,34 @@ + + + + + + + doxia + org.apache.maven.plugins.site.webapp.DoxiaFilter + + + + doxia + /* + +