朱兆平 / imfClient · 提交

转到一个项目

作者 朱兆平
提交 aee6ed7022088612ca436879120c4604c2ff89f0 1 个父辈 7479386e

sender改成单独发吧，对九州的sender发华东数据 优化

内嵌 并排对比
正在显示 3 个修改的文件 包含 4 行增加 和 47 行删除
@@ -57,12 +57,6 @@ public class Main { @@ -57,12 +57,6 @@ public class Main {
57 String sqlmax = ConfigUtils.SQlMax; 57 String sqlmax = ConfigUtils.SQlMax;
58 IMFNoDelaySender CangKu2Jiuzhou = new IMFNoDelaySender(client,"data/fid_index.txt",sql_select,sqlmax); 58 IMFNoDelaySender CangKu2Jiuzhou = new IMFNoDelaySender(client,"data/fid_index.txt",sql_select,sqlmax);
59 CangKu2Jiuzhou.start(); 59 CangKu2Jiuzhou.start();
60 -  
61 - //发送通关数据  
62 - String sql_select1=ConfigUtils.SQl1;  
63 - String sqlmax1 = ConfigUtils.SQlMax1;  
64 - IMFNoDelaySender CangKu2Jiuzhou_tg = new IMFNoDelaySender(client,"data/fid_index_haiguan.txt",sql_select1,sqlmax1);  
65 - CangKu2Jiuzhou_tg.start();  
66 // timer.schedule(CangKu2Jiuzhou, 10000L, 1200000L); 60 // timer.schedule(CangKu2Jiuzhou, 10000L, 1200000L);
67 61
68 } 62 }
@@ -85,19 +85,19 @@ public class IMFNoDelaySender extends Thread{ @@ -85,19 +85,19 @@ public class IMFNoDelaySender extends Thread{
85 String xmlStr = m.getContent(); 85 String xmlStr = m.getContent();
86 //_____________________________________解析华东的报文给九州------------------------------------------------------------------------------------------- 86 //_____________________________________解析华东的报文给九州-------------------------------------------------------------------------------------------
87 if (xmlStr.contains("<MessageType>IS1</MessageType>")){ 87 if (xmlStr.contains("<MessageType>IS1</MessageType>")){
88 - IMFXMLMaker haiguanXml = new IMFXMLMaker("DCKS",Integer.toString(m.getFid()),"DFME","IS1"); 88 + IMFXMLMaker haiguanXml = new IMFXMLMaker(header.getSndr(),Integer.toString(m.getFid()),"DFME","IS1");
89 haiguanXml.setIMFContent(m.getContent()); 89 haiguanXml.setIMFContent(m.getContent());
90 sendMsg = haiguanXml.finalXmlStr(); 90 sendMsg = haiguanXml.finalXmlStr();
91 }else if(xmlStr.contains("<MessageType>ES1</MessageType>") ){ 91 }else if(xmlStr.contains("<MessageType>ES1</MessageType>") ){
92 - IMFXMLMaker haiguanXml = new IMFXMLMaker("DCKS",Integer.toString(m.getFid()),"DFME","ES1"); 92 + IMFXMLMaker haiguanXml = new IMFXMLMaker(header.getSndr(),Integer.toString(m.getFid()),"DFME","ES1");
93 haiguanXml.setIMFContent(m.getContent()); 93 haiguanXml.setIMFContent(m.getContent());
94 sendMsg = haiguanXml.finalXmlStr(); 94 sendMsg = haiguanXml.finalXmlStr();
95 }else if(xmlStr.contains("<MessageType>CLR</MessageType>")){ 95 }else if(xmlStr.contains("<MessageType>CLR</MessageType>")){
96 - IMFXMLMaker haiguanXml = new IMFXMLMaker("DCKS",Integer.toString(m.getFid()),"DFME","CLR"); 96 + IMFXMLMaker haiguanXml = new IMFXMLMaker(header.getSndr(),Integer.toString(m.getFid()),"DFME","CLR");
97 haiguanXml.setIMFContent(m.getContent()); 97 haiguanXml.setIMFContent(m.getContent());
98 sendMsg = haiguanXml.finalXmlStr(); 98 sendMsg = haiguanXml.finalXmlStr();
99 }else if(xmlStr.contains("<MessageType>RSC</MessageType>")){ 99 }else if(xmlStr.contains("<MessageType>RSC</MessageType>")){
100 - IMFXMLMaker haiguanXml = new IMFXMLMaker("DCKS",Integer.toString(m.getFid()),"DFME","RSC"); 100 + IMFXMLMaker haiguanXml = new IMFXMLMaker(header.getSndr(),Integer.toString(m.getFid()),"DFME","RSC");
101 haiguanXml.setIMFContent(m.getContent()); 101 haiguanXml.setIMFContent(m.getContent());
102 sendMsg = haiguanXml.finalXmlStr(); 102 sendMsg = haiguanXml.finalXmlStr();
103 } else { 103 } else {
1 -Manifest-Version: 1.0  
2 -Class-Path: org.springframework.jdbc-3.0.0.CI-331.jar spring-jms-3.0.5  
3 - .RELEASE.jar spring-expression-3.0.5.RELEASE.jar spring-aop-3.0.5.REL  
4 - EASE.jar imfmsg.jar HeartbeatService.jar c3p0-0.9.5.2.jar spring-bean  
5 - s-3.0.5.RELEASE.jar mchange-commons-java-0.2.11.jar UploadService.jar  
6 - spring-core-3.0.5.RELEASE.jar spring-asm-3.0.5.RELEASE.jar apiConfig  
7 - .jar CL3Export.jar CL3Nonexport.jar com.ibm.mq.axis2.jar com.ibm.mq.c  
8 - ommonservices.jar com.ibm.mq.defaultconfig.jar com.ibm.mq.headers.jar  
9 - com.ibm.mq.jar com.ibm.mq.jmqi.jar com.ibm.mq.jms.Nojndi.jar com.ibm  
10 - .mq.pcf.jar com.ibm.mq.postcard.jar com.ibm.mq.soap.jar com.ibm.mq.to  
11 - ols.ras.jar com.ibm.mqetclient.jar com.ibm.mqjms.jar connector.jar dh  
12 - bcore.jar fscontext.jar jms.jar jndi.jar jta.jar ldap.jar provideruti  
13 - l.jar rmm.jar antlr-2.7.7.jar antlr-3.2.jar antlr-runtime-3.2.jar aop  
14 - alliance-1.0.jar asm-3.3.jar bcprov-jdk15-1.45.jar commons-collection  
15 - s-3.2.1.jar commons-lang-2.5.jar commons-logging-1.1.1.jar commons-po  
16 - ol-1.5.5.jar cxf-2.3.2.jar cxf-xjc-boolean-2.3.2.jar cxf-xjc-bug671-2  
17 - .3.2.jar cxf-xjc-dv-2.3.2.jar cxf-xjc-ts-2.3.2.jar FastInfoset-1.2.8.  
18 - jar geronimo-activation_1.1_spec-1.1.jar geronimo-annotation_1.0_spec  
19 - -1.1.1.jar geronimo-javamail_1.4_spec-1.7.1.jar geronimo-jaxws_2.2_sp  
20 - ec-1.0.jar geronimo-jms_1.1_spec-1.1.1.jar geronimo-servlet_3.0_spec-  
21 - 1.0.jar geronimo-stax-api_1.0_spec-1.0.1.jar geronimo-ws-metadata_2.0  
22 - _spec-1.1.3.jar jaxb-api-2.2.1.jar jaxb-impl-2.2.1.1.jar jettison-1.2  
23 - .jar jetty-continuation-7.2.2.v20101205.jar jetty-http-7.2.2.v2010120  
24 - 5.jar jetty-io-7.2.2.v20101205.jar jetty-server-7.2.2.v20101205.jar j  
25 - etty-util-7.2.2.v20101205.jar jra-1.0-alpha-4.jar js-1.7R2.jar jsr173  
26 - _1.0_api.jar jsr311-api-1.1.1.jar neethi-2.0.4.jar oro-2.0.8.jar reso  
27 - lver.jar saaj-api-1.3.jar saaj-impl-1.3.2.jar serializer-2.7.1.jar si  
28 - gar.jar slf4j-api-1.6.1.jar slf4j-jdk14-1.6.1.jar stax2-api-3.0.2.jar  
29 - stringtemplate-3.2.jar velocity-1.6.4.jar woodstox-core-asl-4.0.8.ja  
30 - r wsdl4j-1.6.2.jar wss4j-1.5.11.jar xalan-2.7.1.jar xbean_xpath.jar x  
31 - bean.jar xml-resolver-1.2.jar xmlbeans-2.4.0.jar xmlbeans-qname.jar x  
32 - mlpublic.jar XmlSchema-1.4.7.jar xmlsec-1.4.4.jar com.ibm.mq.fta.jar  
33 - log4j-1.2.16.jar jaxb-xjc-2.2.1.1.jar spring-tx-3.0.5.RELEASE.jar ojd  
34 - bc6.jar jdom-1.1.3.jar IMFClient.1.0.0.jar spring-web-3.0.5.RELEASE.j  
35 - ar spring-context-3.0.5.RELEASE.jar returnXml.jar ProcessService.jar  
36 -Main-Class: com.airport.Main  
37 -