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);
     }