diff options
| -rw-r--r-- | src/rabbit_amqqueue.erl | 1 | ||||
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 2 |
2 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 0abe119854..f04c5fec81 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -48,6 +48,7 @@ -export([notify_sent/2, unblock/2, flush_all/2]). -export([commit_all/3, rollback_all/3, notify_down_all/2, limit_all/3]). -export([on_node_down/1]). +-export([store_queue/1]). -include("rabbit.hrl"). -include_lib("stdlib/include/qlc.hrl"). diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 0560207662..090cb81203 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -39,7 +39,7 @@ remove_from_queue(QueueName, DeadPids) -> _ -> Q1 = Q #amqqueue { pid = QPid1, mirror_pids = MPids1 }, - mnesia:write(rabbit_queue, Q1, write), + ok = rabbit_amqqueue:store_queue(Q1), {ok, QPid1} end end |