diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-12-19 16:32:40 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-12-19 16:32:40 +0000 |
| commit | 76fd4528bbafbccecd8e94f19874e17e85a42959 (patch) | |
| tree | 05303250634ca38ac9c1107993407b3ea99bbd73 /src | |
| parent | 21b9b3d0d7c337fd562e2d03610a7fd8ea1b03dc (diff) | |
| parent | 21e43c8673020db8a6a7dc02c6856ac47a77fbd6 (diff) | |
| download | rabbitmq-server-git-76fd4528bbafbccecd8e94f19874e17e85a42959.tar.gz | |
merging bug 20916 into v1_7
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 22 |
1 files changed, 15 insertions, 7 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 1a5e82d714..d728ef6a76 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -163,15 +163,23 @@ internal_declare(Q = #amqqueue{name = QueueName}, WantDefaultBinding) -> case rabbit_misc:execute_mnesia_transaction( fun () -> case mnesia:wread({rabbit_queue, QueueName}) of - [] -> ok = store_queue(Q), - case WantDefaultBinding of - true -> add_default_binding(Q); - false -> ok - end, - Q; - [ExistingQ] -> ExistingQ + [] -> + case mnesia:read( + {rabbit_durable_queue, QueueName}) of + [] -> ok = store_queue(Q), + case WantDefaultBinding of + true -> add_default_binding(Q); + false -> ok + end, + Q; + [_] -> not_found %% existing Q on stopped node + end; + [ExistingQ] -> + ExistingQ end end) of + not_found -> exit(Q#amqqueue.pid, shutdown), + rabbit_misc:not_found(QueueName); Q -> Q; ExistingQ -> exit(Q#amqqueue.pid, shutdown), ExistingQ |