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 | a45a611ab946a7995de0a3dbd204d26f10f311ab (patch) | |
| tree | cc91cf5cfdcd1c44dafc452daac952112e7c323d | |
| parent | eacc62290fb9675a849bc5c09c4607a19a392bed (diff) | |
| parent | b7802fb4ebabb7377cbebd4bc1ad7f75f07542f3 (diff) | |
| download | rabbitmq-server-a45a611ab946a7995de0a3dbd204d26f10f311ab.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 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}) -> |