etreschenkov 2023-06-28 19:34:55 +03:00
parent db24212cc6
commit 5e7e31066c

View file

@ -56,7 +56,12 @@ public class RestTemplateErrorHandler implements ResponseErrorHandler {
errorMessage = String.format("Error: %s", error);
} else {
OutboundRequest outboundRequest = outboundRequestByUuid.remove(errorResponse.getId());
errorMessage = makeMessage(outboundRequest, errorResponse);
if (outboundRequest != null) {
errorMessage = makeMessage(outboundRequest, errorResponse);
} else {
log.warn("Not found request by uuid: {}; send default error message", errorResponse.getId());
errorMessage = errorResponse.getMessage();
}
}
NotificationNewRequest notificationNewRequest = createNotification(errorMessage);
kafaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, notificationNewRequest);