From 196cb0396e0eae4f9e0ff3e7c671c50c6536faaa Mon Sep 17 00:00:00 2001
From: wyb <1977763549@qq.com>
Date: Fri, 10 Mar 2023 16:59:08 +0800
Subject: [PATCH] =?UTF-8?q?ibmMq=20=E5=90=AF=E5=8A=A8=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                           |  6 ++++++
 .../java/com/docus/server/AppRunBootstrap.java    |  2 +-
 .../collection/receiver/MzZyMqReceiver.java       |  4 ++++
 src/main/resources/bootstrap.yml                  | 15 +++++++++++++++
 4 files changed, 26 insertions(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index aa5f485..8e4f8ad 100644
--- a/pom.xml
+++ b/pom.xml
@@ -175,6 +175,12 @@
             <artifactId>spring-jms</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>com.ibm.mq</groupId>
+            <artifactId>com.ibm.mq.allclient</artifactId>
+            <version>9.1.0.0</version>
+        </dependency>
+
     </dependencies>
     <build>
         <resources>
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