From 61f48be2a607c20d9e1bea6628a48b3b50602b9e Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Tue, 16 Jun 2020 19:58:08 +0800 Subject: [PATCH] --- src/org/redkale/mq/HttpMessageClient.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/org/redkale/mq/HttpMessageClient.java b/src/org/redkale/mq/HttpMessageClient.java index 989d5444d..7f1df8296 100644 --- a/src/org/redkale/mq/HttpMessageClient.java +++ b/src/org/redkale/mq/HttpMessageClient.java @@ -52,6 +52,10 @@ public class HttpMessageClient extends MessageClient { produceMessage(generateHttpReqTopic(request, null), ConvertType.JSON, 0, null, request, counter); } + public final void produceMessage(int userid, HttpSimpleRequest request) { + produceMessage(generateHttpReqTopic(request, null), ConvertType.JSON, userid, null, request, null); + } + public final void produceMessage(int userid, String groupid, HttpSimpleRequest request) { produceMessage(generateHttpReqTopic(request, null), ConvertType.JSON, userid, groupid, request, null); }