diff --git a/stompServer.js b/stompServer.js
index 3454476..46e1f2d 100644
--- a/stompServer.js
+++ b/stompServer.js
@@ -60,7 +60,8 @@ var StompServer = function (config) {
    * @type {object}
    * @property {string} sessionId
    */
-  this.socket.on('connection', function (ws) {
+  this.socket.on('connection', function (ws, incomingMessage) {
+    ws.__req = incomingMessage;
     ws.sessionId = stompUtils.genId();
 
     this.emit('connecting', ws.sessionId);