diff options
| author | Simon MacMullen <simon@lshift.net> | 2010-05-26 17:21:57 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@lshift.net> | 2010-05-26 17:21:57 +0100 |
| commit | 79e0804661b83c72d105db883efffd335963bb32 (patch) | |
| tree | 5714dff9dc663a8fc58813cd30d66edd3d816230 | |
| parent | 0c0026dcc2f70bcf6bcd1ced414955b71c550bdd (diff) | |
| download | rabbitmq-server-git-79e0804661b83c72d105db883efffd335963bb32.tar.gz | |
Don't eat errors that could be returned by F.
| -rw-r--r-- | src/rabbit_channel.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 3db0f95ec0..2751f5b7ea 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -305,18 +305,18 @@ with_exclusive_access_or_die(QName, ReaderPid, F) -> F(Q); #amqqueue{exclusive_owner = ReaderPid} -> F(Q); - E -> - {error, E} + _ -> + {error, wrong_exclusive_owner} end end, case rabbit_amqqueue:with_or_die(QName, F2) of - {error, _} -> + {error, wrong_exclusive_owner} -> rabbit_misc:protocol_error( resource_locked, "cannot obtain exclusive access to locked ~s", [rabbit_misc:rs(QName)]); - Q -> - Q + Else -> + Else end. expand_queue_name_shortcut(<<>>, #ch{ most_recently_declared_queue = <<>> }) -> |
