diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-12-15 11:45:35 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-12-15 11:45:35 +0000 |
| commit | b7802fb4ebabb7377cbebd4bc1ad7f75f07542f3 (patch) | |
| tree | a2c9689d48b211d616c8bcc3b00549155bc7b8d2 | |
| parent | 37a79fa3f83aa88c5114ef68ab3b2461defd3997 (diff) | |
| download | rabbitmq-server-bug24631.tar.gz | |
Ignore force_event_refresh if we have not finished handshaking.bug24631
| -rw-r--r-- | src/rabbit_reader.erl | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 694abd9e..045cc969 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -329,10 +329,14 @@ handle_other({'$gen_call', From, {info, Items}}, Deb, State) -> catch Error -> {error, Error} end), mainloop(Deb, State); -handle_other({'$gen_cast', force_event_refresh}, Deb, State) -> +handle_other({'$gen_cast', force_event_refresh}, Deb, State) + when ?IS_RUNNING(State) -> rabbit_event:notify(connection_created, [{type, network} | infos(?CREATION_EVENT_KEYS, State)]), mainloop(Deb, State); +handle_other({'$gen_cast', force_event_refresh}, Deb, State) -> + %% Ignore, we will emit a created event once we start running. + mainloop(Deb, State); handle_other(emit_stats, Deb, State) -> mainloop(Deb, emit_stats(State)); handle_other({system, From, Request}, Deb, State = #v1{parent = Parent}) -> |