2020-06-03 15:23:45 +08:00
parent e0d224a330
commit de36ef697d
1 changed files with 2 additions and 1 deletions
--- 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();
    }

 }