diff options
| author | Evgeniy Khramtsov <ekhramtsov@process-one.net> | 2017-04-15 13:36:29 +0300 |
|---|---|---|
| committer | Evgeniy Khramtsov <ekhramtsov@process-one.net> | 2017-04-15 13:36:29 +0300 |
| commit | 598c79ff8603b0821d20c32ffc92cfb81ba9bc26 (patch) | |
| tree | 57d44be5e4514d837a8b69c1ae57f51985100a7c /src/ejabberd_router_riak.erl | |
| parent | Add Riak as router RAM backend (diff) | |
Fix cleaning of Riak route table
Diffstat (limited to 'src/ejabberd_router_riak.erl')
| -rw-r--r-- | src/ejabberd_router_riak.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/ejabberd_router_riak.erl b/src/ejabberd_router_riak.erl index 4b270a41..d775e989 100644 --- a/src/ejabberd_router_riak.erl +++ b/src/ejabberd_router_riak.erl @@ -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]), |