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

Browse Source
This commit is contained in:
Redkale
2021-01-06 15:07:31 +08:00
parent 3237e2488e
commit 840cea06db
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/org/redkale/mq/HttpMessageResponse.java
View File

@@ -100,13 +100,17 @@ public class HttpMessageResponse extends HttpResponse {
}
@Override
public void finish(int status, String message) {
if (finest) producer.logger.log(Level.FINEST, "HttpMessageResponse.finish status: " + status);
public void finish(int status, String msg) {
if (status > 400) {
producer.logger.log(Level.INFO, "HttpMessageResponse.finish status: " + status + ", message: " + this.message);
} else if (finest) {
producer.logger.log(Level.FINEST, "HttpMessageResponse.finish status: " + status);
}
if (this.message.isEmptyResptopic()) {
if (callback != null) callback.run();
return;
}
finishHttpResult(new HttpResult(message == null ? "" : message).status(status));
finishHttpResult(new HttpResult(msg == null ? "" : msg).status(status));
}
@Override