diff options
| -rw-r--r-- | src/rabbit_upgrade_functions.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_upgrade_functions.erl b/src/rabbit_upgrade_functions.erl index 632e154f4a..a53ad0c8f9 100644 --- a/src/rabbit_upgrade_functions.erl +++ b/src/rabbit_upgrade_functions.erl @@ -534,8 +534,9 @@ queue_operator_policies(Table) -> queue_vhost_field() -> ok = queue_vhost_field(rabbit_queue), ok = queue_vhost_field(rabbit_durable_queue), - mnesia:add_table_index(rabbit_queue, vhost), - mnesia:add_table_index(rabbit_durable_queue, vhost). + {atomic, ok} = mnesia:add_table_index(rabbit_queue, vhost), + {atomic, ok} = mnesia:add_table_index(rabbit_durable_queue, vhost), + ok. queue_vhost_field(Table) -> transform( |