it is a really simple studies case no ? I can't be the first guy who
don't want to reload the datasource on each line isn't it ?
2013/3/6 Jean Francois LE BESCONT <jflebesc...@gmail.com>
> I made a mistake in my test. It doesn't do what expected ...
>
> Still the same example :
>
> .from(...)
> .split()
> .tokenize("\n")
> .streaming()
> .unmarshal()
> .bindy(BindyType.Csv, AED.class)
> .enrich("direct:refreshReferentielDynamic", new
> AggregationEnrichissementZone())
>
> And a :
>
> from("direct:refreshReferentielDynamic")
> .processRef("validatingProcessor")
>
> .end();
>
>
> And
>
>
> public class ValidatingProcessor implements Processor {
>
> @Autowired
> DriverManagerDataSource dataSource;
> public void process(Exchange exchange) throws Exception {
>
>
> Integer idxParse = (Integer) exchange.getProperty(Exchange.SPLIT_INDEX);
> if (idxParse != null & idxParse == 0) {
> JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
> List<Map<String, Object>> ref = jdbcTemplate
> .queryForList("SELECT ID , CODE , LIBELLE FROM ZONE_T ");
> Map<String, Zone> newRef = new HashMap();
> for (Map<String, Object> map : ref) {
> int id=(Integer) map.get("ID");
> String code =(String) map.get("CODE");
> String libelle =(String)map.get("LIBELLE");
> newRef.put(code, new Zone(id,code,libelle));
> }
> exchange.getOut().setBody(newRef) ;
>
>
> }
> }
>
>
> The problem is that in my AggregationStrategy zones which is populate
> before has data only for the first line ( the first spit index).
>
>
> public class AggregationEnrichissementZone implements AggregationStrategy {
>
> Logger LOG = LoggerFactory.getLogger(AggregationEnrichissementZone.class);
>
> @Override
> public Exchange aggregate(Exchange original, Exchange resource) {
>
> Map<String, Zone> zones = (Map<String, Zone>) resource.getIn().getBody();
>
>
> Any idea ?
>
>
> Thanks !
>
>
>
>
> 2013/3/6 Jean Francois LE BESCONT <jflebesc...@gmail.com>
>
>> Thanks Claus !
>>
>> Tricky but it works :)
>>
>>
>> 2013/3/6 Claus Ibsen <claus.ib...@gmail.com>
>>
>>> On Wed, Mar 6, 2013 at 1:05 PM, Jean Francois LE BESCONT
>>> <jflebesc...@gmail.com> wrote:
>>> > When we do an enrich, the *resourceUri ( in my example
>>> *.enrich("direct:ds",
>>> > new AggregationStrategyRessource())) is called every time.
>>> >
>>> > When I parse a file, big query with all the datasource while be called
>>> > every, is there a trick to tell the route to execute only one ? I have
>>> > watch camel cache but I have understand that it is used for something
>>> else.
>>> >
>>> > Thanks !
>>> >
>>>
>>> You can use a filter / content based route and only use the enrich the
>>> 1st time.
>>> When you use the splitter the exchange has a property with the split
>>> index, so the 1st time the index is zero.
>>>
>>> The key for that property is Exchange.SPLIT_INDEX
>>>
>>> >
>>> >
>>> >
>>> > 2013/3/6 Jean Francois LE BESCONT <jflebesc...@gmail.com>
>>> >
>>> >> Thanks Claus for the link ( have you an HashMap off the FAQ in the
>>> head ?
>>> >> :)
>>> >>
>>> >> Don't forget to add :
>>> >>
>>> >>
>>> >> original.getOut().setHeaders(original.getIn().getHeaders());
>>> >>
>>> >>
>>> >> When enrich with strategy !
>>> >>
>>> >>
>>> >> 2013/3/6 Claus Ibsen <claus.ib...@gmail.com>
>>> >>
>>> >>> On Wed, Mar 6, 2013 at 10:26 AM, Jean Francois LE BESCONT
>>> >>> <jflebesc...@gmail.com> wrote:
>>> >>> > My mistake ...I used resource.getOut().getBody(); instead
>>> >>> > od resource.getIn().getBody();
>>> >>> >
>>> >>>
>>> >>> Yeah see this FAQ
>>> >>>
>>> http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html
>>> >>>
>>> >>> >
>>> >>> > public Exchange aggregate(Exchange original, Exchange resource) {
>>> >>> >
>>> >>> > AED originalBody = (AED)original.getIn().getBody();
>>> >>> > Object resourceResponse = (Object) resource.getIn().getBody();
>>> >>> >
>>> >>> > LOG.info("originalBody " + originalBody ) ;
>>> >>> > LOG.info("resourceResponse " + resourceResponse ) ;
>>> >>> > // do stuff with
>>> >>> >
>>> >>> > return resource;
>>> >>> > }
>>> >>> >
>>> >>> > Thanks raul for the help ! :)
>>> >>> >
>>> >>> >
>>> >>> > 2013/3/6 Jean Francois LE BESCONT <jflebesc...@gmail.com>
>>> >>> >
>>> >>> >> Thanks Raul !
>>> >>> >>
>>> >>> >> I haven't found simple example enrich here (
>>> >>> >> http://camel.apache.org/content-enricher.html, direct:resource in
>>> >>> never
>>> >>> >> explains ). Perharps that I haven't understand fondamental but
>>> it's a
>>> >>> >> huge framework and learning needs time :)
>>> >>> >>
>>> >>> >> So I have a querie :
>>> >>> >>
>>> >>> >> from("direct:refreshReferentielDynamic")
>>> >>> >> .setBody(constant("SELECT * FROM TEST"))
>>> >>> >> .to("jdbc:dataSource")
>>> >>> >> .to("direct:ds")
>>> >>> >> .end();
>>> >>> >>
>>> >>> >> Plus :
>>> >>> >>
>>> >>> >> from("direct:ds").to("log:dans.directds").end();
>>> >>> >>
>>> >>> >> Otherwise it doesn't works.
>>> >>> >>
>>> >>> >>
>>> >>> >> And an " main route " :
>>> >>> >>
>>> >>> >> from("file://....")
>>> >>> >> .split()
>>> >>> >> .tokenize("\n")
>>> >>> >> .enrich("direct:ds", new AggregationStrategyRessource())
>>> >>> >>
>>> >>> >> With :
>>> >>> >>
>>> >>> >>
>>> >>> >> public class AggregationStrategyRessource implements
>>> >>> AggregationStrategy {
>>> >>> >>
>>> >>> >>
>>> >>> >> public Exchange aggregate(Exchange original, Exchange
>>> resource) {
>>> >>> >>
>>> >>> >> return resource; // for the moment
>>> >>> >> }
>>> >>> >>
>>> >>> >> }
>>> >>> >>
>>> >>> >> But original is always null ...
>>> >>> >>
>>> >>> >> Do you see with ?
>>> >>> >>
>>> >>> >>
>>> >>> >>
>>> >>> >>
>>> >>> >>
>>> >>> >>
>>> >>> >>
>>> >>> >> 2013/3/6 Jean Francois LE BESCONT <jflebesc...@gmail.com>
>>> >>> >>
>>> >>> >>> Hey !
>>> >>> >>>
>>> >>> >>> A picture is sometime better than explication :) I try to make a
>>> >>> really
>>> >>> >>> simple test ( equivalent of MAP with lookup in ETL) :
>>> >>> >>>
>>> >>> >>>
>>> >>> >>>
>>> -------------------------
>>> >>> >>> | TABLE TEST |
>>> >>> >>>
>>> -------------------------
>>> >>> >>> | COL1 | COL2 |
>>> >>> >>> | jack | 2 |
>>> >>> >>> | bob | 3 |
>>> >>> >>>
>>> ------------------------
>>> >>> >>> |
>>> >>> >>> |
>>> >>> >>> |
>>> >>> >>> |
>>> >>> >>> |
>>> >>> >>> ---------------- ----------------------
>>> >>> >>> ------------------------
>>> >>> >>> | FILE INPUT | | ENRICH ? |
>>> >>> >>> | FILE OUTPUT |
>>> >>> >>> ---------------- ----------------------
>>> >>> >>> -----------------------
>>> >>> >>> | jack | cool | >>>>>>>>> | | >>>>>>>>>
>>> |
>>> >>> jack
>>> >>> >>> | cool | 2 |
>>> >>> >>> | bob | foo | | |
>>> >>> >>> | bob | foo | 3 |
>>> >>> >>> ----------------
>>> -----------------------
>>> >>> >>> ------------------------
>>> >>> >>>
>>> >>> >>>
>>> >>> >>>
>>> >>> >>>
>>> >>> >>>
>>> >>> >>>
>>> >>> >>>
>>> >>> >>> 2013/3/6 Jean Francois LE BESCONT <jflebesc...@gmail.com>
>>> >>> >>>
>>> >>> >>>> If i do:
>>> >>> >>>> public class AggregationStrategyRessource implements
>>> >>> AggregationStrategy
>>> >>> >>>> {
>>> >>> >>>>
>>> >>> >>>> @Override
>>> >>> >>>> public Exchange aggregate(Exchange original, Exchange
>>> resource) {
>>> >>> >>>> int i = 1 / 0;
>>> >>> >>>> return original;
>>> >>> >>>> }
>>> >>> >>>> }
>>> >>> >>>>
>>> >>> >>>> no exception are thows.
>>> >>> >>>>
>>> >>> >>>>
>>> >>> >>>>
>>> >>> >>>> 2013/3/6 Jean Francois LE BESCONT <jflebesc...@gmail.com>
>>> >>> >>>>
>>> >>> >>>>> thks Raul
>>> >>> >>>>>
>>> >>> >>>>> For the moment it's a simple :
>>> >>> >>>>>
>>> >>> >>>>> public class AggregationStrategyRessource implements
>>> >>> >>>>> AggregationStrategy {
>>> >>> >>>>>
>>> >>> >>>>> @Override
>>> >>> >>>>> public Exchange aggregate(Exchange original, Exchange
>>> resource)
>>> >>> {
>>> >>> >>>>> return original;
>>> >>> >>>>> }
>>> >>> >>>>>
>>> >>> >>>>> }
>>> >>> >>>>>
>>> >>> >>>>> If I put a debug point on it, it is never fired ....
>>> >>> >>>>>
>>> >>> >>>>>
>>> >>> >>>>>
>>> >>> >>>>>
>>> >>> >>>>>
>>> >>> >>>>> 2013/3/6 Raúl Kripalani <r...@evosent.com>
>>> >>> >>>>>
>>> >>> >>>>>> Can we see the code of AggregationStrategyRessource?
>>> >>> >>>>>>
>>> >>> >>>>>> Regards,
>>> >>> >>>>>> Raúl.
>>> >>> >>>>>>
>>> >>> >>>>>> On Mar 5, 2013, at 23:30, Jean Francois LE BESCONT wrote:
>>> >>> >>>>>>
>>> >>> >>>>>> > Hey,
>>> >>> >>>>>> >
>>> >>> >>>>>> > I have this >
>>> >>> >>>>>> >
>>> >>> >>>>>>
>>> >>>
>>> http://camel.465427.n5.nabble.com/Enrich-message-with-data-from-dynamic-sql-query-td5329427.html
>>> >>> >>>>>> >
>>> >>> >>>>>> > But I haven't found a solution to my question.
>>> >>> >>>>>> >
>>> >>> >>>>>> > How can enrich my stream with data from a queries ?
>>> >>> >>>>>> >
>>> >>> >>>>>> > I have a a route called from the start :
>>> >>> >>>>>> >
>>> >>> >>>>>> > from("direct:refreshReferentielDynamic")
>>> >>> >>>>>> > //
>>> >>> >>>>>> > .setBody(constant("SELECT * FROM TEST"))
>>> >>> >>>>>> > //
>>> >>> >>>>>> > .to("jdbc:dataSource")
>>> >>> >>>>>> > //
>>> >>> >>>>>> > .to("direct:ds")
>>> >>> >>>>>> > //
>>> >>> >>>>>> > .end();
>>> >>> >>>>>> >
>>> >>> >>>>>> >
>>> >>> >>>>>> > End I would like to acces data in memory in direct:ds from
>>> an
>>> >>> other
>>> >>> >>>>>> route.
>>> >>> >>>>>> > I have try this :
>>> >>> >>>>>> >
>>> >>> >>>>>> > from("foo").
>>> >>> >>>>>> > [...]
>>> >>> >>>>>> > .enrich("direct:ds", new AggregationStrategyRessource())
>>> >>> >>>>>> >
>>> >>> >>>>>> > But code in AggregationStrategyRessource is not called ...
>>> and
>>> >>> body
>>> >>> >>>>>> is
>>> >>> >>>>>> > replace by the content of the query.
>>> >>> >>>>>> >
>>> >>> >>>>>> > Thks !
>>> >>> >>>>>> >
>>> >>> >>>>>> > Thks !
>>> >>> >>>>>>
>>> >>> >>>>>>
>>> >>> >>>>>
>>> >>> >>>>
>>> >>> >>>
>>> >>> >>
>>> >>>
>>> >>>
>>> >>>
>>> >>> --
>>> >>> Claus Ibsen
>>> >>> -----------------
>>> >>> Red Hat, Inc.
>>> >>> FuseSource is now part of Red Hat
>>> >>> Email: cib...@redhat.com
>>> >>> Web: http://fusesource.com
>>> >>> Twitter: davsclaus
>>> >>> Blog: http://davsclaus.com
>>> >>> Author of Camel in Action: http://www.manning.com/ibsen
>>> >>>
>>> >>
>>> >>
>>>
>>>
>>>
>>> --
>>> Claus Ibsen
>>> -----------------
>>> Red Hat, Inc.
>>> FuseSource is now part of Red Hat
>>> Email: cib...@redhat.com
>>> Web: http://fusesource.com
>>> Twitter: davsclaus
>>> Blog: http://davsclaus.com
>>> Author of Camel in Action: http://www.manning.com/ibsen
>>>
>>
>>
>
