Kaynağa Gözat

MQ消息发送时bug修复

gxt_xa_000000 4 yıl önce
ebeveyn
işleme
c04aceef6a

+ 1 - 1
src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelJDBCConfiguration.java

@@ -440,7 +440,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
440 440
                         .log("${header.date}"+" routeId:centralbase-3->  centralbase.cb_temp_well_mech_daily update date faild")
441 441
                         .end();
442 442
 
443
-                from("timer:mytimer1?period=3600000")
443
+                from("timer:mytimer11?period=3600000")
444 444
                         .routeId("centralbase-1")
445 445
                         .setBody(simple("select so.well_id,so.well_common_name,so.org_id,ti.prod_date,ti.stroke_frequency,ti.stroke_length,ti.sgt from centralbase.cb_temp_well_mech_runtime ti, centralbase.cb_cd_well_source so where ti.well_id = so.well_id and ti.prod_date =(select max(prod_date) from centralbase.cb_temp_well_mech_runtime) "))
446 446
                         .to("jdbc:centralbase")