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 | bd7547a49d051fde5ef278f4e1d8299c1b8da0cb (patch) | |
| tree | a2c9689d48b211d616c8bcc3b00549155bc7b8d2 | |
| parent | 6cf72c5170cf99f37e3c2afaa44a2ee41fbd23bd (diff) | |
| download | rabbitmq-server-git-bd7547a49d051fde5ef278f4e1d8299c1b8da0cb.tar.gz | |
Ignore force_event_refresh if we have not finished handshaking.
| -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 694abd9e49..045cc969af 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}) -> |