Merge branch 'binarin-rabbitmq-server-dead-user-diagnostics' into stable

1 files changed, 9 insertions, 1 deletions

diff --git a/src/rabbit_log.erl b/src/rabbit_log.erl
index c6081fad0d..ed73a293ca 100644
--- a/src/rabbit_log.erl
+++ b/src/rabbit_log.erl
@@ -96,10 +96,18 @@ with_local_io(Fun) ->
     Node = node(),
     case node(GL) of
         Node -> Fun();
-        _    -> group_leader(whereis(user), self()),
+        _    -> set_group_leader_to_user(),
                 try
                     Fun()
                 after
                     group_leader(GL, self())
                 end
     end.
+
+set_group_leader_to_user() ->
+    case whereis(user) of
+        undefined ->
+            warning("the 'user' I/O process has terminated, some features will fail until Erlang VM is restarted");
+        User ->
+            group_leader(User, self())
+    end.