Skip to content

Commit 644b0ec

Browse files
committed
Rename ra_machine_state to ra_machine_config
[#161247406]
1 parent b56db0e commit 644b0ec

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/rabbit_quorum_queue.erl

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -149,9 +149,9 @@ declare(#amqqueue{name = QName,
149149

150150

151151
ra_machine(Q) ->
152-
{module, rabbit_fifo, ra_machine_state(Q)}.
152+
{module, rabbit_fifo, ra_machine_config(Q)}.
153153

154-
ra_machine_state(Q = #amqqueue{name = QName}) ->
154+
ra_machine_config(Q = #amqqueue{name = QName}) ->
155155
#{dead_letter_handler => dlx_mfa(Q),
156156
cancel_consumer_handler => {?MODULE, cancel_consumer, [QName]},
157157
become_leader_handler => {?MODULE, become_leader, [QName]},
@@ -391,7 +391,7 @@ requeue(ConsumerTag, MsgIds, FState) ->
391391

392392
policy_changed(QName, Node) ->
393393
{ok, Q} = rabbit_amqqueue:lookup(QName),
394-
rabbit_fifo_client:update_machine_state(Node, ra_machine_state(Q)).
394+
rabbit_fifo_client:update_machine_state(Node, ra_machine_config(Q)).
395395

396396
cluster_state(Name) ->
397397
case whereis(Name) of

0 commit comments

Comments
 (0)