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-07-13 22:56:42 +08:00
parent 7c5822fb7c
commit 4f5e72a31a
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -53,6 +53,10 @@ public class HttpMessageClient extends MessageClient {
return messageAgent.generateHttpReqTopic(module, resname); return messageAgent.generateHttpReqTopic(module, resname);
} }
public boolean isRetSuccess(HttpResult<byte[]> result) {
return result != null && (result.getStatus() == 0 || result.getStatus() == 200) && result.getHeader("retcode") == null;
}
public final void produceMessage(HttpSimpleRequest request) { public final void produceMessage(HttpSimpleRequest request) {
produceMessage(generateHttpReqTopic(request, null), ConvertType.JSON, 0, null, request, null); produceMessage(generateHttpReqTopic(request, null), ConvertType.JSON, 0, null, request, null);
} }