diff --git a/ixwebsocket/IXWebSocketMessageQueue.cpp b/ixwebsocket/IXWebSocketMessageQueue.cpp
index 10a9da1f..64e9ddb6 100644
--- a/ixwebsocket/IXWebSocketMessageQueue.cpp
+++ b/ixwebsocket/IXWebSocketMessageQueue.cpp
@@ -76,6 +76,11 @@ namespace ix
     {
         _onMessageUserCallback = callback;
     }
+
+    void WebSocketMessageQueue::setOnMessageCallback(OnMessageCallback&& callback)
+    {
+        _onMessageUserCallback = std::move(callback);
+    }
     
     WebSocketMessageQueue::MessagePtr WebSocketMessageQueue::popMessage()
     {
diff --git a/ixwebsocket/IXWebSocketMessageQueue.h b/ixwebsocket/IXWebSocketMessageQueue.h
index 543189e9..b8b85c25 100644
--- a/ixwebsocket/IXWebSocketMessageQueue.h
+++ b/ixwebsocket/IXWebSocketMessageQueue.h
@@ -25,6 +25,7 @@ namespace ix
         void bindWebsocket(WebSocket* websocket);
 
         void setOnMessageCallback(const OnMessageCallback& callback);
+        void setOnMessageCallback(OnMessageCallback&& callback);
 
         void poll(int count = 512);