diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2018-11-08 10:18:37 +0000 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2018-11-08 10:18:37 +0000 |
| commit | 644b0eca35e4e8d8dbecb4232b0b37870dcf6ed1 (patch) | |
| tree | a7356faa05d11c9d0580f80f5c84d4e3a8652fee /src | |
| parent | b56db0e487c6e45aa3fed7a2cb11a9ecc042db9f (diff) | |
| download | rabbitmq-server-git-644b0eca35e4e8d8dbecb4232b0b37870dcf6ed1.tar.gz | |
Rename ra_machine_state to ra_machine_config
[#161247406]
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index acf002748f..cdb1b48451 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -149,9 +149,9 @@ declare(#amqqueue{name = QName, ra_machine(Q) -> - {module, rabbit_fifo, ra_machine_state(Q)}. + {module, rabbit_fifo, ra_machine_config(Q)}. -ra_machine_state(Q = #amqqueue{name = QName}) -> +ra_machine_config(Q = #amqqueue{name = QName}) -> #{dead_letter_handler => dlx_mfa(Q), cancel_consumer_handler => {?MODULE, cancel_consumer, [QName]}, become_leader_handler => {?MODULE, become_leader, [QName]}, @@ -391,7 +391,7 @@ requeue(ConsumerTag, MsgIds, FState) -> policy_changed(QName, Node) -> {ok, Q} = rabbit_amqqueue:lookup(QName), - rabbit_fifo_client:update_machine_state(Node, ra_machine_state(Q)). + rabbit_fifo_client:update_machine_state(Node, ra_machine_config(Q)). cluster_state(Name) -> case whereis(Name) of |