diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-09-15 13:06:51 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-09-15 13:06:51 +0100 |
| commit | 5b05113acc65775b5c7ef3373984c5db7e54ce81 (patch) | |
| tree | 4c26c3159de15477936e200e829e4b38ae8fbc35 | |
| parent | 281eb306a38cfe16f91e702d6cfd95ffde8bdd7a (diff) | |
| download | rabbitmq-server-git-5b05113acc65775b5c7ef3373984c5db7e54ce81.tar.gz | |
Be more assertive, don't assume application.
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 6f299a9eff..54431bcce9 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -582,10 +582,10 @@ delete(#amqqueue{ pid = QPid }, IfUnused, IfEmpty) -> delegate:call(QPid, {delete, IfUnused, IfEmpty}). delete_crashed(#amqqueue{ pid = QPid } = Q) -> - rpc:call(node(QPid), ?MODULE, delete_crashed_internal, [Q]). + ok = rpc:call(node(QPid), ?MODULE, delete_crashed_internal, [Q]). delete_crashed_internal(#amqqueue{ name = QName }) -> - {ok, BQ} = application:get_env(backing_queue_module), + {ok, BQ} = application:get_env(rabbit, backing_queue_module), BQ:delete_crashed(QName), ok = internal_delete(QName). |