@@ -101,7 +101,7 @@ handle_cast(_Msg, State) ->
101
101
102
102
handle_info (? EVAL_MSG , # state {interval = Interval ,
103
103
trigger_interval = TriggerInterval } = State ) ->
104
- Res = reconclitiate_quorum_queue_membership (State ),
104
+ Res = reconciliate_quorum_queue_membership (State ),
105
105
NewTimeout = case Res of
106
106
noop ->
107
107
Interval ;
@@ -125,15 +125,15 @@ code_change(_OldVsn, State, _Extra) ->
125
125
% % Internal functions
126
126
% %----------------------------------------------------------------------------
127
127
128
- reconclitiate_quorum_queue_membership (State ) ->
128
+ reconciliate_quorum_queue_membership (State ) ->
129
129
LocalLeaders = rabbit_amqqueue :list_local_leaders (),
130
130
ExpectedNodes = rabbit_nodes :list_members (),
131
131
Running = rabbit_nodes :list_running (),
132
- reconclitiate_quorum_members (ExpectedNodes , Running , LocalLeaders , State , noop ).
132
+ reconciliate_quorum_members (ExpectedNodes , Running , LocalLeaders , State , noop ).
133
133
134
- reconclitiate_quorum_members (_ExpectedNodes , _Running , [], _State , Result ) ->
134
+ reconciliate_quorum_members (_ExpectedNodes , _Running , [], _State , Result ) ->
135
135
Result ;
136
- reconclitiate_quorum_members (ExpectedNodes , Running , [Q | LocalLeaders ],
136
+ reconciliate_quorum_members (ExpectedNodes , Running , [Q | LocalLeaders ],
137
137
# state {target_group_size = TargetSize } = State ,
138
138
OldResult ) ->
139
139
Result =
@@ -158,7 +158,7 @@ reconclitiate_quorum_members(ExpectedNodes, Running, [Q | LocalLeaders],
158
158
_ ->
159
159
noop
160
160
end ,
161
- reconclitiate_quorum_members (ExpectedNodes , Running , LocalLeaders , State ,
161
+ reconciliate_quorum_members (ExpectedNodes , Running , LocalLeaders , State ,
162
162
update_result (OldResult , Result )).
163
163
164
164
maybe_remove (_ , # state {auto_remove = false }) ->
0 commit comments