From de36ef697dcb4e85fd166cdbb2516eb78792696f Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Wed, 3 Jun 2020 15:23:45 +0800 Subject: [PATCH] --- src/org/redkale/mq/HttpMessageRequest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/org/redkale/mq/HttpMessageRequest.java b/src/org/redkale/mq/HttpMessageRequest.java index 977ace086..8c9142c56 100644 --- a/src/org/redkale/mq/HttpMessageRequest.java +++ b/src/org/redkale/mq/HttpMessageRequest.java @@ -22,7 +22,8 @@ public class HttpMessageRequest extends HttpRequest { public HttpMessageRequest(HttpContext context, MessageRecord reqMessage) { super(context, reqMessage.decodeContent(HttpSimpleRequestCoder.getInstance())); - this.reqMessage = reqMessage; + this.reqMessage = reqMessage; + this.currentUserid = reqMessage.getUserid(); } }