Fix cleaning of Riak route table

This commit is contained in:
Evgeniy Khramtsov 2017-04-15 13:36:29 +03:00
parent da66eb5714
commit 598c79ff86
1 changed files with 2 additions and 2 deletions

View File

@ -74,8 +74,8 @@ clean_table() ->
case ejabberd_riak:get(route, route_schema()) of
{ok, Routes} ->
lists:foreach(
fun(#route{pid = Pid}) ->
ejabberd_riak:delete(route, Pid)
fun(#route{domain = Domain, pid = Pid}) ->
ejabberd_riak:delete(route, {Domain, Pid})
end, Routes);
{error, Err} ->
?ERROR_MSG("failed to clean Riak 'route' table: ~p", [Err]),