diff options
| author | Simon MacMullen <simon@lshift.net> | 2010-05-26 17:03:54 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@lshift.net> | 2010-05-26 17:03:54 +0100 |
| commit | 0c0026dcc2f70bcf6bcd1ced414955b71c550bdd (patch) | |
| tree | 11fb2c7e58c3cab2644e46d57ed451c5f922fa99 /src | |
| parent | ecb23eef0dae5eb6a4a51bd7e5514528aa2a6008 (diff) | |
| download | rabbitmq-server-git-0c0026dcc2f70bcf6bcd1ced414955b71c550bdd.tar.gz | |
Clean up a bit.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_channel.erl | 8 |
2 files changed, 3 insertions, 9 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index e8a745723f..a176dc4643 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -646,8 +646,8 @@ handle_call({basic_consume, NoAck, ChPid, LimiterPid, store_ch_record(C#cr{consumer_count = ConsumerCount +1, limiter_pid = LimiterPid}), ok = case ConsumerCount of - 0 -> rabbit_limiter:register(LimiterPid, self()); - _ -> ok + 0 -> rabbit_limiter:register(LimiterPid, self()); + _ -> ok end, ExclusiveConsumer = if ExclusiveConsume -> {ChPid, ConsumerTag}; true -> ExistingHolder diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 48eeb40a02..3db0f95ec0 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -715,16 +715,10 @@ handle_method(#'queue.declare'{queue = QueueNameBin, check_configure_permitted(QueueName, State), Matched; %% exclusivity trumps non-equivalence arbitrarily - #amqqueue{name = QueueName, - exclusive_owner = ExclusiveOwner} - when ExclusiveOwner =/= Owner -> + #amqqueue{name = QueueName} -> rabbit_misc:protocol_error( resource_locked, "cannot obtain exclusive access to locked ~s", - [rabbit_misc:rs(QueueName)]); - #amqqueue{name = QueueName} -> - rabbit_misc:protocol_error( - channel_error, "parameters for ~s not equivalent", [rabbit_misc:rs(QueueName)]) end end, |