diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_log.erl | 10 |
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. |