更新

src/main/java/com/zswl/dataservice/service/artemis/OperationMessageService.java

@@ -174,12 +174,12 @@ public class OperationMessageService {
             String messageId = message.getJMSMessageID();
             String clientId = message.getStringProperty("__AMQ_CID");
 //            log.info("receiveMessage {} 消息监听clientId: {}", messageId, clientId);
-            log.info("Topic: {}", topicName);
             if (StringUtils.isNotEmpty(topicName) && topicName.endsWith("reply")) {
                 // 这是响应的数据，不处理
 //                log.warn("回复消息不处理");
                 return;
             }
+            log.info("Topic: {}", topicName);
             OperationMessage operationMessage = new OperationMessage();
             operationMessage.setMessageId(messageId);
             operationMessage.setClientId(clientId);
@@ -331,7 +331,7 @@ public class OperationMessageService {
             // 业务处理失败
             entity.setIsHandleSuccess(isHandleSuccess);
             entity.setHandleMsg(handleMsg);
-            log.info("handleMsg: {}", handleMsg);
+            log.info("消息处理结果: {} {}", isHandleSuccess, handleMsg);
             if (isHandleSuccess) {
                 // 处理成功，返回响应
                 responseMessage(entity);