diff --git a/pom.xml b/pom.xml index aa5f485..8e4f8ad 100644 --- a/pom.xml +++ b/pom.xml @@ -175,6 +175,12 @@ spring-jms + + com.ibm.mq + com.ibm.mq.allclient + 9.1.0.0 + + diff --git a/src/main/java/com/docus/server/AppRunBootstrap.java b/src/main/java/com/docus/server/AppRunBootstrap.java index f29c327..819f01f 100644 --- a/src/main/java/com/docus/server/AppRunBootstrap.java +++ b/src/main/java/com/docus/server/AppRunBootstrap.java @@ -10,7 +10,7 @@ import org.springframework.jms.annotation.EnableJms; @Slf4j -@SpringBootApplication(scanBasePackages ={"com.docus"}) +@SpringBootApplication(scanBasePackages ={"com.docus","com.neusoft"}) @EnableJms @MapperScan("com.docus.server.**.mapper") public class AppRunBootstrap { diff --git a/src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java b/src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java index 5bd71c3..f85d34f 100644 --- a/src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java +++ b/src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java @@ -26,6 +26,7 @@ public class MzZyMqReceiver { */ @JmsIbmListener(destination = "TJ_createDepartment") public void revCreateDepartment(String message){ + log.info("注册科室 队列信息:{}",message); } @@ -37,6 +38,7 @@ public class MzZyMqReceiver { */ @JmsIbmListener(destination = "TJ_updateDepartment") public void revUpdateDepartment(String message){ + log.info("变更科室 队列信息:{}",message); } @@ -47,6 +49,7 @@ public class MzZyMqReceiver { */ @JmsIbmListener(destination = "TJ_createPractitioner") public void revCreatePractitioner(String message){ + log.info("人员注册 队列信息:{}",message); } @@ -57,6 +60,7 @@ public class MzZyMqReceiver { */ @JmsIbmListener(destination = "TJ_updatePractitione") public void revUpdatePractitioner(String message){ + log.info("人员变更 队列信息:{}",message); } } diff --git a/src/main/resources/bootstrap.yml b/src/main/resources/bootstrap.yml index d187f88..461cf63 100644 --- a/src/main/resources/bootstrap.yml +++ b/src/main/resources/bootstrap.yml @@ -71,3 +71,18 @@ xxl: port: 17781 logretentiondays: 30 logpath: D:/xxl-job/inspection + + +# com.ibm.mq连接方式(集群模式需要配置两个地址) +ibm: + mq: + queueManager: MqManager01 + channel: chl_server01 + connName: 127.0.0.1(1414) + ackUrl: http://127.0.0.1:7800/ack + domain: CDR + key: cdr-0012-adef + replica: + queueManager: MqManager02 + channel: chl_server02 + connName: 127.0.0.1(1415) \ No newline at end of file