Skip to content

Commit

Permalink
update bindings when there are no new connections to be made (#6657)
Browse files Browse the repository at this point in the history
  • Loading branch information
mark2600 authored Oct 30, 2020
1 parent 1fbde96 commit be141bb
Showing 1 changed file with 7 additions and 1 deletion.
8 changes: 7 additions & 1 deletion core/kazoo_amqp/src/gen_listener.erl
Original file line number Diff line number Diff line change
Expand Up @@ -1418,8 +1418,14 @@ update_federated_bindings(#state{federators=ExistingFederators}=State
,broker_connections(ExistingFederators, FederatedBrokers)
).

maybe_bind_to_federated_bindings(State, {_Existing, []}) ->
maybe_bind_to_federated_bindings(#state{bindings=[{Binding, Props}|_]
,federators=ExistingFederators
}=State
,{_Existing, []}
) ->
lager:debug("all active brokers have federators"),
NonFederatedProps = props:delete('federate', Props),
'ok' = update_existing_listeners_bindings(ExistingFederators, Binding, NonFederatedProps),
State;
maybe_bind_to_federated_bindings(#state{bindings=[{Binding, Props}|_]
,federators=ExistingFederators
Expand Down

0 comments on commit be141bb

Please sign in to comment.