yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix issue #193

This commit is contained in:
Feng 2015-07-14 17:55:52 +08:00
parent c63c74a18f
commit eb097c1056
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGELOG.md
View File

@ -7,6 +7,8 @@ emqttd ChangeLog
Bugfix: issue #189 - MQTT over WebSocket(SSL) cannot work? Bugfix: issue #189 - MQTT over WebSocket(SSL) cannot work?
Bugfix: issue #193 - 'client.ack' hook should be renamed to 'message.acked', and called by emqttd_broker:foreach_hooks
0.9.0-alpha (2015-07-09) 0.9.0-alpha (2015-07-09)
------------------------- -------------------------

2
src/emqttd_session.erl
View File

@ -602,7 +602,7 @@ acked(PktId, Session = #session{client_id = ClientId,
awaiting_ack = Awaiting}) -> awaiting_ack = Awaiting}) ->
case lists:keyfind(PktId, 1, InflightQ) of case lists:keyfind(PktId, 1, InflightQ) of
{_, Msg} -> {_, Msg} ->
emqttd_broker:foldl_hooks('client.acked', [ClientId], Msg); emqttd_broker:foreach_hooks('message.acked', [ClientId, Msg]);
false -> false ->
lager:error("Session(~s) cannot find acked message: ~p", [PktId]) lager:error("Session(~s) cannot find acked message: ~p", [PktId])
end, end,