camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "richie.riviere@gmail.com" <richie.rivi...@gmail.com>
Subject Re: Ideas on how to structure route (alternatives to direct:...)
Date Sat, 14 Dec 2013 06:25:01 GMT
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.

Mime
View raw message