modified pom
This commit is contained in:
@@ -88,11 +88,22 @@ public class Main {
|
||||
.to("activemq:queue:materialTest");
|
||||
|
||||
from("activemq:queue:materialTest")
|
||||
.bean(new DAO(), "test2")
|
||||
.marshal(XMLDataFormat)
|
||||
.to("activemq:queue:test");
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
from("direct:pretty")
|
||||
.setBody(constant("<?xml version='1.0'?>" +
|
||||
"<material>\n" +
|
||||
@@ -117,6 +128,7 @@ public class Main {
|
||||
"</material>\n"))
|
||||
.unmarshal()
|
||||
.jaxb("generated")
|
||||
.bean(new DAO(), "getId")
|
||||
.to("activemq:queue:test")
|
||||
.to("log:?level=INFO&showBody=true");
|
||||
|
||||
@@ -126,7 +138,7 @@ public class Main {
|
||||
|
||||
context.start();
|
||||
ProducerTemplate template = context.createProducerTemplate();
|
||||
template.sendBody("direct:pretty", null);
|
||||
template.sendBody("direct:test", null);
|
||||
Thread.sleep(1000);
|
||||
//template.setDefaultEndpointUri("activemq:queue:material");
|
||||
|
||||
|
||||
Reference in New Issue
Block a user