diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-10-23 10:53:49 +0200 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-10-23 10:53:49 +0200 |
| commit | 2a0126c9644b198d7521ba2b90d990ec1de34c5b (patch) | |
| tree | 6f529ccbef539d199e2a3e635232c2287e43b271 | |
| parent | 4f58002b519b08830352c036a4481694e01bd047 (diff) | |
| download | rabbitmq-server-git-2a0126c9644b198d7521ba2b90d990ec1de34c5b.tar.gz | |
Add comments on force_event_refresh handlingadd-external-connections-for-refresh-event
| -rw-r--r-- | src/rabbit.erl | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl index e7e485dc15..77bd439ce3 100644 --- a/src/rabbit.erl +++ b/src/rabbit.erl @@ -1067,8 +1067,12 @@ config_locations() -> % This event is necessary for the stats timer to be initialized with % the correct values once the management agent has started force_event_refresh(Ref) -> + % direct connections, e.g. MQTT, STOMP ok = rabbit_direct:force_event_refresh(Ref), + % AMQP connections ok = rabbit_networking:force_connection_event_refresh(Ref), + % "external" connections, which are not handled by the "AMQP core", + % e.g. connections to the stream plugin ok = rabbit_networking:force_external_connection_event_refresh(Ref), ok = rabbit_channel:force_event_refresh(Ref), ok = rabbit_amqqueue:force_event_refresh(Ref). |