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

delete

This commit is contained in:
Feng 2015-12-27 21:56:31 +08:00
parent 361096e12b
commit e6e77953f1
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/emqttd_pubsub.erl
View File

@ -175,7 +175,7 @@ delete(topic, _Topic) ->
{error, unsupported}; {error, unsupported};
delete(subscription, ClientId) when is_binary(ClientId) -> delete(subscription, ClientId) when is_binary(ClientId) ->
mnesia:dirty_deleate({subscription, ClientId}); mnesia:dirty_delete({subscription, ClientId});
delete(subscription, {ClientId, Topic}) when is_binary(ClientId) -> delete(subscription, {ClientId, Topic}) when is_binary(ClientId) ->
mnesia:async_dirty(fun remove_subscriptions/2, [ClientId, [Topic]]). mnesia:async_dirty(fun remove_subscriptions/2, [ClientId, [Topic]]).