lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2020-06-08 22:51:14 +08:00
parent 30bf2c1ad3
commit fa9fc531d0
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/mq/HttpMessageProcessor.java
View File

@@ -47,7 +47,9 @@ public class HttpMessageProcessor implements MessageProcessor {
HttpMessageResponse response = new HttpMessageResponse(context, request, null, null, producer); HttpMessageResponse response = new HttpMessageResponse(context, request, null, null, producer);
servlet.execute(request, response); servlet.execute(request, response);
} catch (Exception ex) { } catch (Exception ex) {
HttpMessageResponse.finishHttpResult(message, producer, message.getResptopic(), new HttpResult().status(500)); if (message.getResptopic() != null && !message.getResptopic().isEmpty()) {
HttpMessageResponse.finishHttpResult(message, producer, message.getResptopic(), new HttpResult().status(500));
}
logger.log(Level.SEVERE, HttpMessageProcessor.class.getSimpleName() + " process error, message=" + message, ex); logger.log(Level.SEVERE, HttpMessageProcessor.class.getSimpleName() + " process error, message=" + message, ex);
} }
} }