diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_core_ff.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_table.erl | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_core_ff.erl b/src/rabbit_core_ff.erl index 461a43e5d9..24d2163f16 100644 --- a/src/rabbit_core_ff.erl +++ b/src/rabbit_core_ff.erl @@ -44,12 +44,12 @@ quorum_queue_migration(FeatureName, _FeatureProps, enable) -> Tables = ?quorum_queue_tables, - rabbit_table:wait(Tables), + rabbit_table:wait(Tables, _Retry = true), Fields = amqqueue:fields(amqqueue_v2), migrate_to_amqqueue_with_type(FeatureName, Tables, Fields); quorum_queue_migration(_FeatureName, _FeatureProps, is_enabled) -> Tables = ?quorum_queue_tables, - rabbit_table:wait(Tables), + rabbit_table:wait(Tables, _Retry = true), Fields = amqqueue:fields(amqqueue_v2), mnesia:table_info(rabbit_queue, attributes) =:= Fields andalso mnesia:table_info(rabbit_durable_queue, attributes) =:= Fields. diff --git a/src/rabbit_table.erl b/src/rabbit_table.erl index 60e9c9dac2..7dfc5fb573 100644 --- a/src/rabbit_table.erl +++ b/src/rabbit_table.erl @@ -16,7 +16,7 @@ -module(rabbit_table). --export([create/0, create_local_copy/1, wait_for_replicated/1, wait/1, +-export([create/0, create_local_copy/1, wait_for_replicated/1, wait/1, wait/2, force_load/0, is_present/0, is_empty/0, needs_default_data/0, check_schema_integrity/1, clear_ram_only_tables/0, retry_timeout/0, wait_for_replicated/0]). |