@@ -1267,18 +1267,19 @@ handle_call({basic_consume, NoAck, ChPid, LimiterPid, LimiterActive,
12671267 false ->
12681268 case check_exclusive_access (Holder , ExclusiveConsume , State ) of
12691269 in_use -> {error , reply ({error , exclusive_consume_unavailable }, State )};
1270- ok -> Consumers1 = rabbit_queue_consumers :add (
1271- ChPid , ConsumerTag , NoAck ,
1272- LimiterPid , LimiterActive ,
1273- PrefetchCount , Args , is_empty (State ),
1274- ActingUser , Consumers ),
1275- ExclusiveConsumer =
1276- if ExclusiveConsume -> {ChPid , ConsumerTag };
1277- true -> Holder
1278- end ,
1279- {state , State # q {consumers = Consumers1 ,
1280- has_had_consumers = true ,
1281- active_consumer = ExclusiveConsumer }}
1270+ ok ->
1271+ Consumers1 = rabbit_queue_consumers :add (
1272+ ChPid , ConsumerTag , NoAck ,
1273+ LimiterPid , LimiterActive ,
1274+ PrefetchCount , Args , is_empty (State ),
1275+ ActingUser , Consumers ),
1276+ ExclusiveConsumer =
1277+ if ExclusiveConsume -> {ChPid , ConsumerTag };
1278+ true -> Holder
1279+ end ,
1280+ {state , State # q {consumers = Consumers1 ,
1281+ has_had_consumers = true ,
1282+ active_consumer = ExclusiveConsumer }}
12821283 end
12831284 end ,
12841285 case ConsumerRegistration of
0 commit comments