the mullticast example you posted looks good. I thought multi cast was just
for parallel. Now that I know it's not i'll look into it.
So with the multicast example you posted does it do them in order? I'll have
a read of doco. Here are the post processing routes...
public void configure() throws Exception {
LOG.debug("Executing
ItemImportPostProcessingConfigurableItemsRoute ...");
from("direct:itemImportRoute")
.routeId("itemImportPostProcessingConfigurableItemsRoute")
.autoStartup(true)
.startupOrder(2)
.shutdownRoute(ShutdownRoute.Defer)
.errorHandler(deadLetterChannel("log:dead")
.retryAttemptedLogLevel(LoggingLevel.ERROR))
.setHeader("notProcessed", constant(DaoConstants.NOT_PROCESSED))
.to("sql:{{sql.notProcessed}}?dataSourceRef=dataSource")
.to("sqlComponentSelectInputProcessor")
.to("sql:{{sql.configurableScenarioOne}}")
.to("sqlComponentSelectInputProcessor")
.to("sql:{{sql.updateConfigurableScenarioOne}}")
.to("direct:itemImportPostProcessingConfigurableItemsRoute");
}
}
public void configure() throws Exception {
LOG.debug("Executing ItemImportPostProcessingSimpleItemsRoute
...");
from("direct:itemImportPostProcessingConfigurableItemsRoute")
.routeId("itemImportPostProcessingSimpleItemsRoute")
.autoStartup(true)
.startupOrder(3)
.shutdownRoute(ShutdownRoute.Defer)
.errorHandler(deadLetterChannel("log:dead")
.retryAttemptedLogLevel(LoggingLevel.ERROR))
.setHeader("notProcessed", constant(DaoConstants.NOT_PROCESSED))
.to("sql:{{sql.notProcessed}}?dataSourceRef=dataSource")
.to("sqlComponentSelectInputProcessor")
.to("sql:{{sql.simpleScenarioOne}}")
.to("sqlComponentSelectInputProcessor")
.to("sql:{{sql.updateSimpleScenarioOne}}")
.to("direct:itemImportPostProcessingSimpleItemsRoute");
}
public void configure() throws Exception {
LOG.debug("Executing
ItemImportPostProcessingVisibleInCatAndSearchItemsRoute ...");
from("direct:itemImportPostProcessingSimpleItemsRoute")
.routeId("itemImportPostProcessingVisibleInCatAndSearchItemsRoute")
.autoStartup(true)
.startupOrder(4)
.shutdownRoute(ShutdownRoute.Defer)
.errorHandler(deadLetterChannel("log:dead")
.retryAttemptedLogLevel(LoggingLevel.ERROR))
.setHeader("notProcessed", constant(DaoConstants.NOT_PROCESSED))
.to("sql:{{sql.notProcessed}}?dataSourceRef=dataSource")
.to("sqlComponentSelectInputProcessor")
.to("sql:{{sql.visibleInSearchAndCatalog}}")
.to("sqlComponentSelectInputProcessor")
.to("sql:{{sql.updateVisibleInSearchAndCatalog}}")
.to("direct:itemImportPostProcessingVisibleInCatAndSearchItemsRoute");
}
public void configure() throws Exception {
LOG.debug("Executing
ItemImportPostProcessingNotVisibleItemsRoute ...");
from("direct:itemImportPostProcessingVisibleInCatAndSearchItemsRoute")
.routeId("itemImportPostProcessingNotVisibleItemsRoute")
.autoStartup(true)
.startupOrder(5)
.shutdownRoute(ShutdownRoute.Defer)
.errorHandler(deadLetterChannel("log:dead")
.retryAttemptedLogLevel(LoggingLevel.ERROR))
.setHeader("notProcessed", constant(DaoConstants.NOT_PROCESSED))
.to("sql:{{sql.notProcessed}}?dataSourceRef=dataSource")
.to("sqlComponentSelectInputProcessor")
.to("sql:{{sql.visibleInSearchAndCatalog}}")
.to("sqlComponentSelectInputProcessor")
.to("sql:{{sql.updateVisibleInSearchAndCatalog}}")
.to("direct:itemImportPostProcessingNotVisibleItemsRoute");
}
--
View this message in context:
http://camel.465427.n5.nabble.com/Ideas-on-how-to-structure-route-alternatives-to-direct-tp5744748p5744752.html
Sent from the Camel - Users mailing list archive at Nabble.com.
