diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-01-08 17:14:34 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-01-08 19:27:48 +0300 |
| commit | 12bee7e718891ecfe97412201461a2aa34fb540c (patch) | |
| tree | aa88e5387e8cc362e96e52b5c5bd58fcf82dd48e /src | |
| parent | 1613055c33a224ccd2101c8cf53466756e45bf43 (diff) | |
| download | rabbitmq-server-git-12bee7e718891ecfe97412201461a2aa34fb540c.tar.gz | |
Formatting
(cherry picked from commit 28bef208e44a11af12e4b2d000c9ff52a60f54a1)
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 25 |
1 files changed, 13 insertions, 12 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 5f56955ccc..37ee8d0a15 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1267,18 +1267,19 @@ handle_call({basic_consume, NoAck, ChPid, LimiterPid, LimiterActive, false -> case check_exclusive_access(Holder, ExclusiveConsume, State) of in_use -> {error, reply({error, exclusive_consume_unavailable}, State)}; - ok -> Consumers1 = rabbit_queue_consumers:add( - ChPid, ConsumerTag, NoAck, - LimiterPid, LimiterActive, - PrefetchCount, Args, is_empty(State), - ActingUser, Consumers), - ExclusiveConsumer = - if ExclusiveConsume -> {ChPid, ConsumerTag}; - true -> Holder - end, - {state, State#q{consumers = Consumers1, - has_had_consumers = true, - active_consumer = ExclusiveConsumer}} + ok -> + Consumers1 = rabbit_queue_consumers:add( + ChPid, ConsumerTag, NoAck, + LimiterPid, LimiterActive, + PrefetchCount, Args, is_empty(State), + ActingUser, Consumers), + ExclusiveConsumer = + if ExclusiveConsume -> {ChPid, ConsumerTag}; + true -> Holder + end, + {state, State#q{consumers = Consumers1, + has_had_consumers = true, + active_consumer = ExclusiveConsumer}} end end, case ConsumerRegistration of |