diff options
| -rw-r--r-- | deps/rabbit/src/rabbit_quorum_queue.erl | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_quorum_queue.erl b/deps/rabbit/src/rabbit_quorum_queue.erl index 5e5b5d2dcb..aeceae7caf 100644 --- a/deps/rabbit/src/rabbit_quorum_queue.erl +++ b/deps/rabbit/src/rabbit_quorum_queue.erl @@ -976,8 +976,15 @@ maybe_delete_data_dir(UId) -> policy_changed(Q) -> QPid = amqqueue:get_pid(Q), - _ = rabbit_fifo_client:update_machine_state(QPid, ra_machine_config(Q)), - ok. + case rabbit_fifo_client:update_machine_state(QPid, ra_machine_config(Q)) of + ok -> + ok; + Err -> + FormattedQueueName = rabbit_misc:rs(amqqueue:get_name(Q)), + rabbit_log:warning("~s: policy may not have been successfully applied. Error: ~p", + [FormattedQueueName, Err]), + ok + end. -spec cluster_state(Name :: atom()) -> 'down' | 'recovering' | 'running'. |