Merge pull request #1974 from rabbitmq/rabbitmq-server-1973

Make sure amq.rabbitmq.log is accessible to client connections

1 files changed, 5 insertions, 4 deletions

diff --git a/src/lager_exchange_backend.erl b/src/lager_exchange_backend.erl
index e1af365b4d..ced1611883 100644
--- a/src/lager_exchange_backend.erl
+++ b/src/lager_exchange_backend.erl
@@ -187,13 +187,14 @@ 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, Exchange}
     catch
         ErrType:Err ->
-            rabbit_log:debug("Could not initialize exchange '~s' in vhost '~s', reason: ~p:~p",
+            rabbit_log:error("Could not declare exchange '~s' in vhost '~s', reason: ~p:~p",
                              [?LOG_EXCH_NAME, DefaultVHost, ErrType, Err]),
             {ok, undefined}
     end;