Commit 47c02bfc authored by yanzg's avatar yanzg

修改日志打印功能,打印更加详细的日志

parent 01dbca58
...@@ -193,7 +193,7 @@ public class MessageServeServiceImpl implements MessageServerService, Initializi ...@@ -193,7 +193,7 @@ public class MessageServeServiceImpl implements MessageServerService, Initializi
sendServerMessage(msg); sendServerMessage(msg);
} catch (Exception ex) { } catch (Exception ex) {
ex.printStackTrace(); ex.printStackTrace();
Log.error(MqServiceImpl.class, ex); Log.error(MessageServeServiceImpl.class, ex);
} finally { } finally {
messageSendService.basicAck(message, channel); messageSendService.basicAck(message, channel);
} }
...@@ -235,7 +235,7 @@ public class MessageServeServiceImpl implements MessageServerService, Initializi ...@@ -235,7 +235,7 @@ public class MessageServeServiceImpl implements MessageServerService, Initializi
// 发送消息,等待下次重新发送 // 发送消息,等待下次重新发送
req.addPos(); req.addPos();
if (!req.isNext()) { if (!req.isNext()) {
Log.error(MqServiceImpl.class, "达到最大次数,不会继续发送"); Log.error(MessageServeServiceImpl.class, "达到最大次数,不会继续发送");
return StringHelper.EMPTY; return StringHelper.EMPTY;
} }
...@@ -263,7 +263,8 @@ public class MessageServeServiceImpl implements MessageServerService, Initializi ...@@ -263,7 +263,8 @@ public class MessageServeServiceImpl implements MessageServerService, Initializi
} }
} }
} catch (Exception ex) { } catch (Exception ex) {
Log.error(MqServiceImpl.class, ex); Log.error(MessageServeServiceImpl.class, ex);
ex.printStackTrace();
} }
if (sendQueueName.isEmpty()) { if (sendQueueName.isEmpty()) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment