diff options
Diffstat (limited to 'components/service_discovery/src/service_discovery_rpc.erl')
| -rw-r--r-- | components/service_discovery/src/service_discovery_rpc.erl | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/components/service_discovery/src/service_discovery_rpc.erl b/components/service_discovery/src/service_discovery_rpc.erl index b67a7a9..b3d2a4d 100644 --- a/components/service_discovery/src/service_discovery_rpc.erl +++ b/components/service_discovery/src/service_discovery_rpc.erl @@ -395,6 +395,14 @@ notify_subscribers(CompSpec, Available, Services, DataLinkModule) -> unavailable -> service_unavailable end, + + ets:foldl( + %% Notify if this is not the originating service. + fun(#subscriber_entry { module = Module }, Acc) -> + ?debug(" notify_subscribers module: ~p ", [ Module]), + ok + end, ok, ?SUBSCRIBER_TABLE), + %% Initiate with the first module notify_single_subscriber(CompSpec, ets:first(?SUBSCRIBER_TABLE), |