diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-04-10 14:01:41 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-04-10 14:01:41 +0300 |
| commit | 12a8ca6d6632d5452dca21c5a67ad5c21a6a4c97 (patch) | |
| tree | 4d8f24f4f5d976fee10cbfd1a0861854964d1026 | |
| parent | 99e883e3fedb58270ac6b6b8e83982f4ef3e7038 (diff) | |
| download | rabbitmq-server-git-12a8ca6d6632d5452dca21c5a67ad5c21a6a4c97.tar.gz | |
Make sure amq.rabbitmq.log is accessible to client connections
That is, not an internal exchange.
Closes #1973, references #1456.
[#165243321]
| -rw-r--r-- | src/lager_exchange_backend.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/lager_exchange_backend.erl b/src/lager_exchange_backend.erl index e1af365b4d..8c14b3f5d6 100644 --- a/src/lager_exchange_backend.erl +++ b/src/lager_exchange_backend.erl @@ -187,10 +187,11 @@ maybe_init_exchange(State) -> %% @private init_exchange(true) -> {ok, DefaultVHost} = application:get_env(rabbit, default_vhost), - VHost = rabbit_misc:r(DefaultVHost, exchange, ?LOG_EXCH_NAME), + Exchange = rabbit_misc:r(DefaultVHost, exchange, ?LOG_EXCH_NAME), try - #exchange{} = rabbit_exchange:declare(VHost, topic, true, false, true, [], ?INTERNAL_USER), - {ok, #resource{virtual_host=DefaultVHost, kind=exchange, name=?LOG_EXCH_NAME}} + %% durable + #exchange{} = rabbit_exchange:declare(Exchange, topic, true, false, false, [], ?INTERNAL_USER), + {ok, #resource{virtual_host = DefaultVHost, kind = exchange, name = ?LOG_EXCH_NAME}} catch ErrType:Err -> rabbit_log:debug("Could not initialize exchange '~s' in vhost '~s', reason: ~p:~p", |