From def3fc7b2ef804aa367d4f2e810aa630351a02a9 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Sun, 3 Jan 2021 12:04:51 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/HttpMessageClient.java | 7 +++++++
 1 file changed, 7 insertions(+)

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 <T> CompletableFuture<T> sendMessage(int userid, String groupid, HttpSimpleRequest request, Type type) {
+        return sendMessage(generateHttpReqTopic(request, null), userid, groupid, request, null).thenApply((HttpResult<byte[]> httbs) -> {
+            if (httbs == null || httbs.getResult() == null) return null;
+            return JsonConvert.root().convertFrom(type, httbs.getResult());
+        });
+    }
+
     public final CompletableFuture<HttpResult<byte[]>> sendMessage(HttpSimpleRequest request) {
         return sendMessage(generateHttpReqTopic(request, null), 0, null, request, null);
     }