Hi,
To store the aggregated results, you need to create a separate table in
your database.
Then you can add something like the following statement to your route
after the aggregation:
.to("sql:insert into messages (doctype, messageID) values (:#doctype,
:#messageID)");
The values of the named parameters will be taken from the corresponding
headers in the aggregated Exchange.
On 05/04/2022 10:12, Reto Peter wrote:
Hi
Using the JdbcAggregationRepository I am trying to save the relation between my
incoming messages and the aggregate, as a 1-n relation. It is actually the EDI
Messages (Single message) into the EDI Interchange (Collection of messages).
When I run the route, I see that the entries are available in the my-SQL
aggregation table.
If the aggregate is finished, then all the entries are gone, both tables
aggregation and aggregation_completed are empty
Is that normal? Or Do I have an error somewhere in my setup?
I was trying to find another solution to get my relation saved. In my AggregatorStrategy class, in
the aggregate method I did save a list of messages, and in the onCompletion method, I set that list
as a Header. This works only if I use the correlationExpression 'true', but actually I do aggregate
messages with same doctype like "DESADV" and "INVOIC" and then the value of the
Header is always just the one from the last processed aggregate
My route looks like this (simplified)
from("file:{{dir.from}}")
.choice()
.when()....setHeader("doctype").constant("DESADV")
.when()....setHeader("doctype").constant("INVOICE")
.aggregate(header("doctype"), new
EDIMessageToInterchangeAggregator()).aggregationRepository("repo3")
.log("Header: ${header.messageIDList}") // Shows always the latest Aggregate
Header only
If I run message for one doctype only, then it all works, cause there will only
be one aggregate
My bean config is like this:
<bean id="repo3"
class="org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository">
<property name="repositoryName" value="test_aggregation"/>
<property name="transactionManager" ref="txManager"/>
<property name="dataSource" ref="datasource"/>
<!-- configure to store the message body and following headers as text
in the repo -->
<property name="storeBodyAsText" value="true"/>
<property name="headersToStoreAsText">
<list>
<value>doctype</value>
<value>messageID</value>
<value>interchangeID</value>
</list>
</property>
</bean>
<bean id="txManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="datasource"/>
</bean>
