소스 검색

1.清除lfq的配置,dev连接到57数据库上,用于检测异常情况
2.gatway增加log的流程用于写出出参入参
3.JMS修订Body的输出

Airhead 8 년 전
부모
커밋
48f3a240cb
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      hos-broker/src/main/java/com/yihu/hos/broker/common/log/JMSAppender.java

+ 2 - 2
hos-broker/src/main/java/com/yihu/hos/broker/common/log/JMSAppender.java

@ -279,7 +279,7 @@ public class JMSAppender extends AppenderSkeleton {
            }
            ObjectMessage msg = topicSession.createObjectMessage();
            String message = event.getMessage().toString();
            String body = message.substring(message.indexOf("Body:") + 5);
//            String body = message.substring(message.indexOf("Body:") + 5);
            Map<String, String> map = new HashMap<>();
            map.put("exchangeId", StringUtil.toString(event.getMDC("camel.exchangeId")));
            map.put("correlationId", StringUtil.toString(event.getMDC("camel.correlationId")));
@ -287,7 +287,7 @@ public class JMSAppender extends AppenderSkeleton {
            map.put("routeId", StringUtil.toString(event.getMDC("camel.routeId")));
            map.put("breadcrumbId", StringUtil.toString(event.getMDC("camel.breadcrumbId")));
            map.put("camelContextId", StringUtil.toString(event.getMDC("camel.contextId")));
            map.put("body", body);
            map.put("body", message);
            map.put("fireTimeSource", DateUtil.toStringFormatGMTTime(DateUtil.toGMTTime(event.getTimeStamp()), DateUtil.DEFAULT_TIMESTAMP_FORMAT));
            msg.setObject(JSONObject.fromObject(map).toString());