diff --git a/src/org/redkale/mq/HttpMessageClient.java b/src/org/redkale/mq/HttpMessageClient.java index 8e633d017..b3e58ad2e 100644 --- a/src/org/redkale/mq/HttpMessageClient.java +++ b/src/org/redkale/mq/HttpMessageClient.java @@ -132,6 +132,13 @@ public class HttpMessageClient extends MessageClient { }); } + public final CompletableFuture sendMessage(int userid, String groupid, HttpSimpleRequest request, Type type) { + return sendMessage(generateHttpReqTopic(request, null), userid, groupid, request, null).thenApply((HttpResult httbs) -> { + if (httbs == null || httbs.getResult() == null) return null; + return JsonConvert.root().convertFrom(type, httbs.getResult()); + }); + } + public final CompletableFuture> sendMessage(HttpSimpleRequest request) { return sendMessage(generateHttpReqTopic(request, null), 0, null, request, null); }