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
