camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrè <>
Subject Re: what did i forgot? Bean integration through direct:start
Date Wed, 15 Jun 2011 10:16:07 GMT
ok, let me explain: 
i have serveral routes
        <from uri="file:src/data?noop=true"/>
        <to uri="activemq:topic:personnel.records"/>
        <from uri="activemq:topic:personnel.records"/>
        <policy ref="droolsPolicy">
            <description>Generate some processes to embedded
            <unmarshal ref="myjaxb"/>
            <to uri="drools:node1/ksession1?action=insertBody"/>
            <marshal ref="myjaxb"/>
        <from uri="drools:node1/ksession1?channel=SipChannel"/>
        <to uri="file:target/messages/sip"/>
        <log message="XACML  receives"/>
        <from uri="drools:node1/ksession1?channel=StsChannel"/>
        <to uri="file:target/messages/sts"/>
        <log message="STS Channel receives"/>
        <from uri="activemq:topic:xacml.authzRequests"/>
        <log message="request consumed hopefully"/>
        <to uri="file:target/messages/requests"/>
        <from uri="file:src/requests?noop=true"/>
        <to uri="activemq:topic:xacml.authzRequests"/>
 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
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:
Sent from the Camel - Users mailing list archive at

View raw message