summaryrefslogtreecommitdiff
path: root/src/rabbit.erl
diff options
context:
space:
mode:
authorLuke Bakken <lbakken@pivotal.io>2019-04-10 15:49:07 -0700
committerLuke Bakken <lbakken@pivotal.io>2019-04-10 15:49:07 -0700
commit10a834d4c35dfd8affff45d5c0d2a1dc52fc7cd2 (patch)
tree99f77eab70bb79a7909064eb6ba3f7b8be14b787 /src/rabbit.erl
parentfb6a83b63b415042b8f512545f3a2d506f2d5e83 (diff)
downloadrabbitmq-server-git-10a834d4c35dfd8affff45d5c0d2a1dc52fc7cd2.tar.gz
Add code to declare amq.rabbitmq.log exchange immediately after the / vhost is added or recovered
Diffstat (limited to 'src/rabbit.erl')
-rw-r--r--src/rabbit.erl6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl
index dafdaed5c9..1210e467ec 100644
--- a/src/rabbit.erl
+++ b/src/rabbit.erl
@@ -1031,8 +1031,9 @@ boot_delegate() ->
-spec recover() -> 'ok'.
recover() ->
- rabbit_policy:recover(),
- rabbit_vhost:recover().
+ ok = rabbit_policy:recover(),
+ ok = rabbit_vhost:recover(),
+ ok = lager_exchange_backend:maybe_init_exchange().
-spec maybe_insert_default_data() -> 'ok'.
@@ -1058,6 +1059,7 @@ insert_default_data() ->
DefaultReadPermBin = rabbit_data_coercion:to_binary(DefaultReadPerm),
ok = rabbit_vhost:add(DefaultVHostBin, ?INTERNAL_USER),
+ ok = lager_exchange_backend:maybe_init_exchange(),
ok = rabbit_auth_backend_internal:add_user(
DefaultUserBin,
DefaultPassBin,