diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-05-27 19:52:27 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-05-27 19:52:27 +0100 |
| commit | 97eaa3fde5fce6137dde1e6c28f545f7c88be5d0 (patch) | |
| tree | 6f0318e660f1431e5f925d6a4a7d8061790a781b | |
| parent | 9c18fbf76f549e081121337bf160b98008e801b4 (diff) | |
| download | rabbitmq-server-97eaa3fde5fce6137dde1e6c28f545f7c88be5d0.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_channel.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 3c5220ca..490dd31d 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -700,8 +700,8 @@ handle_method(#'queue.declare'{queue = QueueNameBin, %% We use this in both branches, because queue_declare may yet return an %% existing queue. Finish = - fun(#amqqueue{name = QueueName, exclusive_owner = Owner1} = Q) - when Owner =:= Owner1 -> + fun (#amqqueue{name = QueueName, exclusive_owner = Owner1} = Q) + when Owner =:= Owner1 -> %% "equivalent" rule. NB: we don't pay attention to %% anything in the arguments table, so for the sake of %% the "equivalent" rule, all tables of arguments are @@ -716,7 +716,7 @@ handle_method(#'queue.declare'{queue = QueueNameBin, _ -> ok = rabbit_reader_queue_collector:register_exclusive_queue(CollectorPid, Q) end, Q; - (#amqqueue{name = QueueName}) -> + (#amqqueue{name = QueueName}) -> %% exclusivity trumps non-equivalence arbitrarily rabbit_misc:protocol_error( resource_locked, @@ -747,7 +747,7 @@ handle_method(#'queue.declare'{queue = QueueNameBin, reader_pid = ReaderPid}) -> QueueName = rabbit_misc:r(VHostPath, queue, QueueNameBin), check_configure_permitted(QueueName, State), - Q = with_exclusive_access_or_die(QueueName, ReaderPid, fun(Q) -> Q end), + Q = with_exclusive_access_or_die(QueueName, ReaderPid, fun (Q) -> Q end), return_queue_declare_ok(State, NoWait, Q); handle_method(#'queue.delete'{queue = QueueNameBin, |