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 | 894b6d98993b48ce763d68efc8a6947d20775ad1 (patch) | |
| tree | 4c26c3159de15477936e200e829e4b38ae8fbc35 | |
| parent | 083cb59506ea2539392d3d9fed118a1b0d8fad17 (diff) | |
| download | rabbitmq-server-894b6d98993b48ce763d68efc8a6947d20775ad1.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 6f299a9e..54431bcc 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). |