summaryrefslogtreecommitdiff
path: root/src/rabbit_queue_consumers.erl
Commit message (Expand)AuthorAgeFilesLines
* Switch to Mozilla Public License 2.0 (MPL 2.0)dcorbacho2020-07-101-12/+3
* Update copyright (year 2020)Jean-Sébastien Pédron2020-03-101-1/+1
* (c) bumpMichael Klishin2019-12-291-1/+1
* URL CleanupSpring Operator2019-03-201-1/+1
* Fix more Dialyzer warningsLoïc Hoguin2019-02-121-2/+2
* Move `-spec()` near their functionJean-Sébastien Pédron2019-02-011-39/+59
* Return active and activity status when listing consumersArnaud Cogoluègnes2019-01-211-15/+23
* Add single active field when listing consumersArnaud Cogoluègnes2019-01-161-6/+15
* Integrate single active consumer with metricsArnaud Cogoluègnes2019-01-151-1/+9
* Clarify commentsMichael Klishin2019-01-081-2/+2
* FormattingMichael Klishin2019-01-081-1/+1
* Merge branch 'master' into rabbitmq-server-1743-exclusive-consumerArnaud Cogoluègnes2018-12-111-8/+10
|\
| * Replace a couple instances of queue with lqueueLuke Bakken2018-12-051-8/+10
* | Use single active consumer term when appropriateArnaud Cogoluègnes2018-11-221-9/+9
* | Merge branch 'master' into rabbitmq-server-1743-exclusive-consumerArnaud Cogoluègnes2018-11-221-2/+4
|\ \ | |/
| * Quorum queues (#1706)Karl Nilsson2018-10-291-2/+4
* | Check exclusive consumer isn't blocked before deliveryArnaud Cogoluègnes2018-10-241-9/+23
* | Pick new exclusive consumer after channel goes downArnaud Cogoluègnes2018-10-231-1/+6
* | Implement exclusive consumer (WIP)Arnaud Cogoluègnes2018-10-221-7/+45
|/
* Replace orddicts with mapsDaniil Fedotov2017-10-301-3/+3
* Replace dicts with maps for queue mirroring logic.Daniil Fedotov2017-04-211-2/+3
* Merge branch 'stable'Michael Klishin2017-04-021-1/+1
|\
| * (c) yearMichael Klishin2017-04-021-1/+1
* | Add user ID to consumersDiana Corbacho2017-01-151-8/+10
* | Merge branch 'stable'Jean-Sébastien Pédron2016-06-291-4/+0
|\ \ | |/
| * Use the new -spec formatJean-Sébastien Pédron2016-06-281-4/+0
* | Bump minimal erlang version to 18.3Daniil Fedotov2016-05-121-5/+5
|/
* Update (c) infoMichael Klishin2016-01-011-1/+1
* Ignore unknown channel acks in queueDaniil Fedotov2015-12-141-1/+3
* Avoid division by 0Jean-Sébastien Pédron2015-08-111-0/+2
* Use monotonic_time() to compute elapsed timeJean-Sébastien Pédron2015-08-051-7/+7
* (c) yearMichael Klishin2015-05-241-1/+1
* erase_ch/2 should return ctags for just the erased channel, not all of them.Simon MacMullen2015-03-301-5/+9
* When we add a new consumer we might be inactive; make sure we transition to a...Simon MacMullen2014-09-251-2/+4
* Update copyright for 2014Simon MacMullen2014-03-171-1/+1
* Merge bug25957Simon MacMullen2014-03-061-36/+60
|\
| * Strip out support for x-prefetch.Simon MacMullen2014-03-041-5/+1
| * Management information on per-consumer prefetchSimon MacMullen2014-03-041-7/+9
| * Change the semantics of the basic.qos global flag to switch between per-consu...Simon MacMullen2014-03-041-8/+9
| * update_counter--Matthias Radestock2014-02-041-4/+3
| * Don't reinvent orddict:update_counter/3.Simon MacMullen2014-02-041-14/+6
| * Manage AckTag -> Ctag mapping in rabbit_queue_consumers, leave the channel ou...Simon MacMullen2014-02-031-15/+33
| * Merge defaultSimon MacMullen2014-02-031-18/+34
| |\
| | * merge default into bug24297Matthias Radestock2014-01-221-9/+9
| | |\
| | * \ merge default into bug24297Matthias Radestock2014-01-221-15/+14
| | |\ \
| | * | | We can't have drain=true and mode=auto so let's unify to a single mode: manua...Simon MacMullen2014-01-151-13/+15
| | * | | Unify rabbit_limiter:credit/5 and rabbit_limiter:set_consumer_prefetch/4.Simon MacMullen2014-01-151-13/+11
| | * | | Move credit args parsing into rabbit_queue_consumers, to reduce some nasty ar...Simon MacMullen2014-01-151-6/+18
| | * | | Undo gratuitous rename.Simon MacMullen2014-01-151-6/+6
| | * | | Rearrange order of function args in ack/reject/requeue for consistency.Simon MacMullen2014-01-141-2/+2
View Lorry Controller Status