优化mq日志等级

yun-zuoyi
汪云昊 5 years ago
parent cc59162c14
commit d8f50038ed

@ -38,7 +38,7 @@ public class I3CoreQueueReceiver {
@RabbitListener(queues = QUEUE_IMPP_MESSAGE) @RabbitListener(queues = QUEUE_IMPP_MESSAGE)
public void processImppMessage(SysMessage msg, Channel channel, Message message) { public void processImppMessage(SysMessage msg, Channel channel, Message message) {
try { try {
LOGGER.info("【MQ-QUEUE_IMPP_MESSAGE】数据接收成功{}",msg); LOGGER.debug("【MQ-QUEUE_IMPP_MESSAGE】数据接收成功{}",msg);
//信息已处理 //信息已处理
channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);

@ -66,7 +66,7 @@ public class MessageLetterQueueReceiver {
*/ */
@RabbitListener(queues = PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER) @RabbitListener(queues = PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER)
public void processImppMessage(String data, Channel channel, Message message) { public void processImppMessage(String data, Channel channel, Message message) {
LOGGER.info("【MQ-{}】 数据接收成功:{}", PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER, data); LOGGER.debug("【MQ-{}】 数据接收成功:{}", PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER, data);
SysMessage msg = JsonUtilTool.decode(data, SysMessage.class); SysMessage msg = JsonUtilTool.decode(data, SysMessage.class);
try { try {
ConvertBean.serviceModelInitialize(msg, "system"); ConvertBean.serviceModelInitialize(msg, "system");

@ -55,7 +55,7 @@ public class MessageMailQueueReceiver {
SysMessage msg = JsonUtilTool.decode(data, SysMessage.class); SysMessage msg = JsonUtilTool.decode(data, SysMessage.class);
Long startTime = System.currentTimeMillis(); Long startTime = System.currentTimeMillis();
try { try {
LOGGER.info("【MQ-QUEUE_IMPP_MESSAGE_MAIL】数据接收成功{}", msg); LOGGER.debug("【MQ-QUEUE_IMPP_MESSAGE_MAIL】数据接收成功{}", msg);
if (msg.getMessageSendTime() == null) { if (msg.getMessageSendTime() == null) {
msg.setMessageSendTime(TimeTool.getNowTime(true)); msg.setMessageSendTime(TimeTool.getNowTime(true));
} }

@ -60,7 +60,7 @@ public class MessageSWebNoticeQueueReceiver {
*/ */
@RabbitListener(queues = PlatformConstWords.QUEUE_SWEB_NOTICE) @RabbitListener(queues = PlatformConstWords.QUEUE_SWEB_NOTICE)
public void processImppMail(String data, Channel channel, Message message) { public void processImppMail(String data, Channel channel, Message message) {
LOGGER.info("【MQ-{}】 数据接收成功:{}", PlatformConstWords.QUEUE_SWEB_NOTICE, data); LOGGER.debug("【MQ-{}】 数据接收成功:{}", PlatformConstWords.QUEUE_SWEB_NOTICE, data);
// 添加消息 // 添加消息
SysMessage msg = JsonUtilTool.decode(data, SysMessage.class); SysMessage msg = JsonUtilTool.decode(data, SysMessage.class);
try { try {

@ -59,7 +59,7 @@ public class ScheduleQueueReceiver {
public void processSchedule(String data, Channel channel, Message message) { public void processSchedule(String data, Channel channel, Message message) {
try { try {
SysLogTaskTime logTaskTime = JsonUtilTool.decode(data, SysLogTaskTime.class); SysLogTaskTime logTaskTime = JsonUtilTool.decode(data, SysLogTaskTime.class);
LOGGER.info("【MQ-QUEUE_IMPP_SCHEDULE】数据接收成功{}", logTaskTime); LOGGER.debug("【MQ-QUEUE_IMPP_SCHEDULE】数据接收成功{}", logTaskTime);
// 跟新最后执行时间 及 任务状态 // 跟新最后执行时间 及 任务状态
if(logTaskTime != null){ if(logTaskTime != null){
SysTaskPlan taskPlan = sysTaskPlanService.getSysTaskPlanByNameAndGroup(logTaskTime.getName(), logTaskTime.getGroupName()); SysTaskPlan taskPlan = sysTaskPlanService.getSysTaskPlanByNameAndGroup(logTaskTime.getName(), logTaskTime.getGroupName());

Loading…
Cancel
Save