diff options
| author | Daniil Fedotov <dfedotov@pivotal.io> | 2016-10-20 11:10:39 +0100 |
|---|---|---|
| committer | Daniil Fedotov <dfedotov@pivotal.io> | 2016-10-20 14:49:52 +0100 |
| commit | 36f3e6791cb12ba5ab448a330baa11b3eae64e9a (patch) | |
| tree | e895fef920aa8337bf8ff84d9850e5ce2fec9263 | |
| parent | 8a45f409c3177505b342ad33f0c3d84cb04359db (diff) | |
| download | rabbitmq-server-git-36f3e6791cb12ba5ab448a330baa11b3eae64e9a.tar.gz | |
Purge vhost storage in transaction
| -rw-r--r-- | src/rabbit_vhost.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_vhost.erl b/src/rabbit_vhost.erl index a277c275ed..2f323fc41b 100644 --- a/src/rabbit_vhost.erl +++ b/src/rabbit_vhost.erl @@ -94,7 +94,6 @@ delete(VHostPath) -> with(VHostPath, fun () -> internal_delete(VHostPath) end)), ok = rabbit_event:notify(vhost_deleted, [{name, VHostPath}]), [ok = Fun() || Fun <- Funs], - purge_messages(VHostPath), ok. purge_messages(VHostPath) -> @@ -129,6 +128,7 @@ internal_delete(VHostPath) -> Fs2 = [rabbit_policy:delete(VHostPath, proplists:get_value(name, Info)) || Info <- rabbit_policy:list(VHostPath)], ok = mnesia:delete({rabbit_vhost, VHostPath}), + purge_messages(VHostPath), Fs1 ++ Fs2. exists(VHostPath) -> |