Databases
StackOverflow2013
Postsdbo
POStop route when all messages are filtered
 

Note that there are some explanatory texts on larger screens.

plurals
  1. POStop route when all messages are filtered
    primarykey
    data
    text
    <p>I have a batch route that consumes XML files from a folder. It filters, transforms and finally saves a grouped document to disk. As this is a batch route, I require it to be shut down after a single polling of the sourcefolder, which is what the RouteTerminator is for in the code below. (It calls <code>stopRoute()</code> and <code>removeRoute()</code> on <code>camelContext</code> with <code>routeID</code>.)</p> <pre><code>from("file:" + sourcePath) .filter().xquery("//DateTime &gt; xs:dateTime('2013-05-07T23:59:59')") .filter().xquery("//DateTime &lt; xs:dateTime('2013-05-09T00:00:00')") .aggregate(constant(true)) .completionFromBatchConsumer() .groupExchanges() .to("xquery:" + xqueryPath) .to("file:" + targetPath) .process(new Processor() { @Override public void process(Exchange exchange) throws Exception { new RouteTerminator(routeID, exchange.getContext()).start(); } }) .end(); </code></pre> <p>This correctly closes the route after a single file collection and after repeating the process in <code>onException</code> it also gracefully closes the route when an exception is thrown. Unfortunately, if the route filters out every Exchange, it never reaches the processor. Exchanges are instead dropped during the filter and the route remains open.</p> <p>I thought to move the filter inside the <code>aggregate</code> call as this might keep the route going until the end, but this method won't accept XQuery filters. XPath is not an option as it does not support dateTime comparisons.</p> <p>How can I force the entire route to stop in this case?</p>
    singulars
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. PTQuestion
    1. USLilienthal
    1. USLilienthal
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. COI've found a very hacky way to do this by inserting one bogus record into the exchange in a bean and then filtering this record out in the XQuery that I call but I'd obviously prefer a cleaner approach.
      singulars
      1. POStop route when all messages are filtered
      1. USLilienthal
    2. COInstead of using filter, have you contemplated on using CHOICE predicate
      singulars
      1. POStop route when all messages are filtered
      1. USJoe2013
    3. CO@Joe2013 I had but it didn't work very well. After your comment I tried again and now have a solution where I call `setHeader` to set a `Filtered` header. Unfortunately I can't seem to break out of the `choice` to use it as a simple switch/case so I have to route both the `.when()` and `.otherwise()` to the same second direct route. In that route I then aggregate and call a basic merge bean that builds a Document out of every Exchange and adds it to a GenericFile if the header matches. It seems like there should be an easier way to simply set a header based on an xquery though...
      singulars
      1. POStop route when all messages are filtered
      1. USLilienthal
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload