|
|
@ -36,12 +36,12 @@ public class RabbitMqListener { |
|
|
//2.处理消息
|
|
|
//2.处理消息
|
|
|
MessageHandler.handleMessage(inMessage); |
|
|
MessageHandler.handleMessage(inMessage); |
|
|
}catch (Exception e){ |
|
|
}catch (Exception e){ |
|
|
e.printStackTrace(); |
|
|
logger.error("发送消息异常",e); |
|
|
try { |
|
|
try { |
|
|
MessageHandler.handleMessage( |
|
|
MessageHandler.handleMessage( |
|
|
InMessage.newToServerMessage(MessageConstant.DomainType.Queue,new UnExceptedErrorMessage(e.getMessage()))); |
|
|
InMessage.newToServerMessage(MessageConstant.DomainType.Queue,new UnExceptedErrorMessage(e.getMessage()))); |
|
|
} catch (Exception ex) { |
|
|
} catch (Exception ex) { |
|
|
ex.printStackTrace(); |
|
|
logger.error("发送消息异常2",ex); |
|
|
} |
|
|
} |
|
|
logger.error("Rabbit Process Message Failed: {},{}",e.getMessage(),messageJson); |
|
|
logger.error("Rabbit Process Message Failed: {},{}",e.getMessage(),messageJson); |
|
|
} |
|
|
} |
|
|
|