Skip to content

Commit 88f90a2

Browse files
Merge pull request #3067 from rabbitmq/mk-sync-tables-with-retries-in-exchange-plugins
{consistent_hash,recent_history}_exchange plugins: add retries to schema sync (cherry picked from commit 1ff28f1)
1 parent 021dd09 commit 88f90a2

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

deps/rabbitmq_consistent_hash_exchange/src/rabbit_exchange_type_consistent_hash.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ init() ->
5353
{attributes, record_info(fields, chx_hash_ring)},
5454
{type, ordered_set}]),
5555
mnesia:add_table_copy(?HASH_RING_STATE_TABLE, node(), ram_copies),
56-
mnesia:wait_for_tables([?HASH_RING_STATE_TABLE], 30000),
56+
rabbit_table:wait([?HASH_RING_STATE_TABLE]),
5757
recover(),
5858
ok.
5959

deps/rabbitmq_recent_history_exchange/src/rabbit_exchange_type_recent_history.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ setup_schema() ->
128128
{record_name, cached},
129129
{type, set}]),
130130
mnesia:add_table_copy(?RH_TABLE, node(), ram_copies),
131-
mnesia:wait_for_tables([?RH_TABLE], 30000),
131+
rabbit_table:wait([?RH_TABLE]),
132132
ok.
133133

134134
disable_plugin() ->

0 commit comments

Comments
 (0)