ok, let me explain:
i have serveral routes
<route>
<from uri="file:src/data?noop=true"/>
<to uri="activemq:topic:personnel.records"/>
</route>
<route>
<from uri="activemq:topic:personnel.records"/>
<policy ref="droolsPolicy">
<description>Generate some processes to embedded
drools</description>
<unmarshal ref="myjaxb"/>
<to uri="drools:node1/ksession1?action=insertBody"/>
<marshal ref="myjaxb"/>
</policy>
</route>
<route>
<from uri="drools:node1/ksession1?channel=SipChannel"/>
<to uri="file:target/messages/sip"/>
<log message="XACML receives"/>
</route>
<route>
<from uri="drools:node1/ksession1?channel=StsChannel"/>
<to uri="file:target/messages/sts"/>
<log message="STS Channel receives"/>
</route>
<route>
<from uri="activemq:topic:xacml.authzRequests"/>
<log message="request consumed hopefully"/>
<to uri="file:target/messages/requests"/>
</route>
<route>
<from uri="file:src/requests?noop=true"/>
<to uri="activemq:topic:xacml.authzRequests"/>
</route>
for example sending xml files to an activemq.topic and a route which
consumes from that topic and writes it to an file endpoint
the result is this :
4343 [org.apache.
072 [org.apache.camel.spring.Main.main()] INFO
org.apache.camel.component.file.FileEndpoint - Endpoint is configured with
noop=true so forcing endpoint to be idempotent as well
4072 [org.apache.camel.spring.Main.main()] INFO
org.apache.camel.component.file.FileEndpoint - Using default memory based
idempotent repository with cache max size: 1000
4112 [org.apache.camel.spring.Main.main()] INFO
org.apache.camel.spring.SpringCamelContext - Route: route1 started and
consuming from: Endpoint[file://src/data?noop=true]
4502 [ActiveMQ Task-1] INFO
org.apache.activemq.transport.failover.FailoverTransport - Successfully
connected to tcp://localhost:61616
4552 [org.apache.camel.spring.Main.main()] INFO
org.apache.camel.spring.SpringCamelContext - Route: route2 started and
consuming from: Endpoint[activemq://topic:personnel.records]
4562 [org.apache.camel.spring.Main.main()] INFO
org.apache.camel.spring.SpringCamelContext - Route: route3 started and
consuming from: Endpoint[drools://node1/ksession1?channel=SipChannel]
4572 [org.apache.camel.spring.Main.main()] INFO
org.apache.camel.spring.SpringCamelContext - Route: route4 started and
consuming from: Endpoint[drools://node1/ksession1?channel=StsChannel]
4602 [ActiveMQ Task-2] INFO
org.apache.activemq.transport.failover.FailoverTransport - Successfully
connected to tcp://localhost:61616
4612 [org.apache.camel.spring.Main.main()] INFO
org.apache.camel.spring.SpringCamelContext - Route: route5 started and
consuming from: Endpoint[activemq://topic:xacml.authzRequests]
4622 [org.apache.camel.spring.Main.main()] INFO
org.apache.camel.spring.SpringCamelContext - Route: route6 started and
consuming from: Endpoint[file://src/requests?noop=true]
4632 [org.apache.camel.spring.Main.main()] INFO
org.apache.camel.spring.SpringCamelContext - Total 6 routes, of which 6 is
started.
4632 [org.apache.camel.spring.Main.main()] INFO
org.apache.camel.spring.SpringCamelContext - Apache Camel 2.7.1
(CamelContext: camel-1) started in 1.140 seconds
Rule 04 Works jon
5203 [Thread-2] INFO route3 - XACML receives
Rule 01 Workshiram
Rule 04 Works hiram
5243 [Thread-2] INFO route3 - XACML receives
Rule 02 Workshiram
Rule 01 Workshiram
Rule 02 Workshiram
Rule 01 Workshiram
Rule 02 Workshiram
Rule 04 Works james
5243 [Thread-2] INFO route3 - XACML receives
(there seems also to be an problem cause the failover transtransport is
loaded twice, sounds not that correct, but i don´t know)
it´s working correctly!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
so what i want to do now is not sending an xml file to an endpoint , i want
to send an RequestCtx Object (XACML thing) to an Endpoint
so i want firstly to parse the xml file, which i´m now sending directly, and
send the object.
in the camel bean-component doc i read, that the bean component is just to
consume objects, that´s why i used the direct-component
after that i saw that consume/produce annotations and they sounded helping
to consume the file and then produce this obejct by using the direct
component, or didn´t i catch the real usage of that annotations?
(all i know is that it seems to me that it´s not working that way *g*)
--
View this message in context:
http://camel.465427.n5.nabble.com/what-did-i-forgot-Bean-integration-through-direct-start-tp4490510p4490743.html
Sent from the Camel - Users mailing list archive at Nabble.com.
