diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-12-21 13:31:42 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-12-21 13:31:42 +0000 |
| commit | 16cb3e23c90901b599898eb6c6e8e73e4981c61d (patch) | |
| tree | 5d2a93eff61e6b5fdd5c92d183bf3d152938994e | |
| parent | 17aec78d02bfe35fbe9a231a8a058cc654e13afe (diff) | |
| download | rabbitmq-server-git-16cb3e23c90901b599898eb6c6e8e73e4981c61d.tar.gz | |
Use amqqueue:store_queue/1 so that we modify durable queues durably
| -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 |