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