diff options
| author | Evgeny Khramtsov <ekhramtsov@process-one.net> | 2019-04-25 14:30:42 +0300 |
|---|---|---|
| committer | Evgeny Khramtsov <ekhramtsov@process-one.net> | 2019-04-25 14:30:42 +0300 |
| commit | a0c8c70c9cbe7b8cb35d799c8504157bb75e7486 (patch) | |
| tree | 76ec599f8a7d7486a8204aec0137a07ce1078e56 /src/ejabberd_websocket.erl | |
| parent | Merge pull request #2868 from rstgroup/fix-rfc-6455-violation (diff) | |
Use binary framing in MQTT WebSockets
Diffstat (limited to 'src/ejabberd_websocket.erl')
| -rw-r--r-- | src/ejabberd_websocket.erl | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/ejabberd_websocket.erl b/src/ejabberd_websocket.erl index edc602f5..2b5a0146 100644 --- a/src/ejabberd_websocket.erl +++ b/src/ejabberd_websocket.erl @@ -202,10 +202,14 @@ ws_loop(FrameInfo, Socket, WsHandleLoopPid, SocketMode) -> end, erlang:demonitor(Ref), websocket_close(Socket, WsHandleLoopPid, SocketMode, Code); - {send, Data} -> + {text, Data} -> SocketMode:send(Socket, encode_frame(Data, 1)), ws_loop(FrameInfo, Socket, WsHandleLoopPid, SocketMode); + {data, Data} -> + SocketMode:send(Socket, encode_frame(Data, 2)), + ws_loop(FrameInfo, Socket, WsHandleLoopPid, + SocketMode); {ping, Data} -> SocketMode:send(Socket, encode_frame(Data, 9)), ws_loop(FrameInfo, Socket, WsHandleLoopPid, |