diff options
| author | Daniil Fedotov <dfedotov@pivotal.io> | 2017-03-01 18:37:36 +0000 |
|---|---|---|
| committer | Daniil Fedotov <dfedotov@pivotal.io> | 2017-03-01 18:38:53 +0000 |
| commit | e746abffca500d4ed5dc06e5cfb00a8a11a012a1 (patch) | |
| tree | f1d53c8f54e998449fd03ae19bbaf056b2207f43 | |
| parent | c40f527f4a73e17e2cb2563515845737dbca21b5 (diff) | |
| download | rabbitmq-server-git-e746abffca500d4ed5dc06e5cfb00a8a11a012a1.tar.gz | |
Add missing acting user for internal function
| -rw-r--r-- | src/rabbit_vhost.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_vhost.erl b/src/rabbit_vhost.erl index 726b39cf28..7b43017e30 100644 --- a/src/rabbit_vhost.erl +++ b/src/rabbit_vhost.erl @@ -87,9 +87,9 @@ delete(VHostPath, ActingUser) -> %% notifications which must be sent outside the TX rabbit_log:info("Deleting vhost '~s'~n", [VHostPath]), QDelFun = fun (Q) -> rabbit_amqqueue:delete(Q, false, false, ActingUser) end, - [assert_benign(rabbit_amqqueue:with(Name, QDelFun)) || + [assert_benign(rabbit_amqqueue:with(Name, QDelFun), ActingUser) || #amqqueue{name = Name} <- rabbit_amqqueue:list(VHostPath)], - [assert_benign(rabbit_exchange:delete(Name, false, ActingUser)) || + [assert_benign(rabbit_exchange:delete(Name, false, ActingUser), ActingUser) || #exchange{name = Name} <- rabbit_exchange:list(VHostPath)], Funs = rabbit_misc:execute_mnesia_transaction( with(VHostPath, fun () -> internal_delete(VHostPath, ActingUser) end)), @@ -108,13 +108,13 @@ purge_messages(VHost) -> %% above. rabbit_variable_queue:stop_vhost_msg_store(VHost). -assert_benign(ok) -> ok; -assert_benign({ok, _}) -> ok; -assert_benign({error, not_found}) -> ok; -assert_benign({error, {absent, Q, _}}) -> +assert_benign(ok, _) -> ok; +assert_benign({ok, _}, _) -> ok; +assert_benign({error, not_found}, _) -> ok; +assert_benign({error, {absent, Q, _}}, ActingUser) -> %% Removing the mnesia entries here is safe. If/when the down node %% restarts, it will clear out the on-disk storage of the queue. - case rabbit_amqqueue:internal_delete(Q#amqqueue.name) of + case rabbit_amqqueue:internal_delete(Q#amqqueue.name, ActingUser) of ok -> ok; {error, not_found} -> ok end. |
