| | |
| | | multicastEvent(serviceCode, targetDataFlowEvent, asyn); |
| | | } catch (Exception e) { |
| | | logger.error("发布侦听失败,失败原因为:", e); |
| | | throw new BusinessException(ResponseConstant.RESULT_CODE_INNER_ERROR, "发布侦听失败,失败原因为:" + e.getMessage()); |
| | | throw new BusinessException(ResponseConstant.RESULT_CODE_INNER_ERROR, e.getMessage()); |
| | | } |
| | | |
| | | } |
| | |
| | | listener.soService(event); |
| | | } catch (Exception e) { |
| | | LoggerEngine.error("发布侦听失败", e); |
| | | throw new RuntimeException("发布侦听失败," + listener + event + e); |
| | | throw new RuntimeException(e.getMessage()); |
| | | } |
| | | } |
| | | } |