|
|
@@ -1088,6 +1088,11 @@ parse(Data) ->
|
|
|
Parser = emqx_stomp_frame:initial_parse_state(ProtoEnv),
|
|
|
emqx_stomp_frame:parse(Data, Parser).
|
|
|
|
|
|
+get_field(command, #stomp_frame{command = Command}) ->
|
|
|
+ Command;
|
|
|
+get_field(body, #stomp_frame{body = Body}) ->
|
|
|
+ Body.
|
|
|
+
|
|
|
send_connection_frame(Sock, Username, Password) ->
|
|
|
send_connection_frame(Sock, Username, Password, <<"0,0">>).
|
|
|
|