×

Welcome to TagMyCode

Please login or create account to add a snippet.
0
0
 
0
Language: Java
Posted by: Jonathan Vila López
Added: Jun 18, 2014 12:05 PM
Views: 21
Tags: no tags
routebuilder
  1. public class CamelRoutePUSH extends RouteBuilder {
  2.   @Override
  3.   public void configure() throws Exception {
  4.     getContext().setTracing(false);
  5.    
  6.     // Temporizadamente ejecutaremos ...
  7.     //from("quartz://tesipro/tesiprocon-dispo?trigger.repeatInterval=60000&trigger.repeatCount=0").
  8.     from("timer://tesipro?fixedRate=true&period=60000").
  9.            
  10.     log("**************** Ejecucion de Quartz - 1 *********************").
  11.    
  12.     // Obtendremos los registros de la BD
  13.     beanRef("uploadARIService", "getEventosPrecio").
  14.            
  15.     to("log:foo?multiline=true&showAll=true&level=INFO").
  16.  
  17.     // Generaremos paquetes agrupando por el CODIGOHOT y Maximo 100 registros por hotel
  18.     aggregate(simple("${body}.codigohot"), AggregationStrategies.bean(AgregadorEventos.class, "agregaEventoPrecio")).
  19.            
  20.     completionSize(100).completionTimeout(3000).
  21.  
  22.     log("..............................").
  23.     to("log:foo?multiline=true&showAll=true&level=INFO").
  24.  
  25.     log(" -------------------------------------------------------------");
  26.    
  27.   }
  28.  
  29.  
  30. }