Check the response to the CONNECT frame to see if there was an error

wingify · Jun 2, 2016 · 8449534 · 8449534
1 parent a3bbff0
commit 8449534
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/lib/resty/rabbitmqstomp.lua b/lib/resty/rabbitmqstomp.lua
@@ -116,8 +116,18 @@ function _login(self)
         return nil, err
     end
 
+    local frame, err = _receive_frame(self)
+    if not frame then
+        return nil, err
+    end
+
+    -- We successfully received a frame, but it was an ERROR frame
+    if sub( frame, 1, len( 'ERROR' ) ) == 'ERROR' then
+        return nil, frame
+    end
+
     self.state = STATE_CONNECTED
-    return _receive_frame(self)
+    return frame
 end