diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-12-15 21:35:21 +0000 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-12-15 21:35:21 +0000 |
| commit | 636b2f8e2c59326e13c4d6730e5cfca0ae20ba29 (patch) | |
| tree | cc91cf5cfdcd1c44dafc452daac952112e7c323d | |
| parent | 0c9e226a06f4a1b6f4c842e3e4775ccd1135beb7 (diff) | |
| parent | bd7547a49d051fde5ef278f4e1d8299c1b8da0cb (diff) | |
| download | rabbitmq-server-git-636b2f8e2c59326e13c4d6730e5cfca0ae20ba29.tar.gz | |
Merged bug24631 into default
| -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}) -> |